为了进行测试，我设法运行了一个嵌入式独立pulsar服务器和客户端。我还可以发送和接收消息。然而，我实际上想(集成-)测试功能(实现org.apache.pulsar.functions.api.Function)。如何在嵌入式设置中注册函数？import org.apache.pulsar.PulsarStandaloneBuilder
import org.apache.pulsar.broker.PulsarS
浏览 26提问于2019-06-09得票数 1
回答已采纳
1回答
如何确定哪个测试处于挂起状态？
、、、、
我有一个测试挂着..。当我尝试从Maven运行测试时，它总是以ManagedLedgerTest结尾，如下所示：
[INFO] Running org.apache.bookkeeper.client.PulsarMockReadHandle当我将代码推送到我们的构建服务器时，我们看到了完全相同的行为。pulsar-broker,!pulsar-proxy,!pulsar-brokeruth-sasl,!pulsar-io/kafka-con
浏览 1提问于2020-02-09得票数 0
我在Go代码中引用了一个包为：但是，在构建用于设置集成测试的坞映像时，我需要包括对该库的一些本地更改。(虽然这不会带来我的本地更改，但只是为了测试)我得到：
# github.com/apache/pulsar/pulsar-function-go/examples/t
浏览 4提问于2020-01-23得票数 0
(Native.java:247) at org.apache.pulsar.shade.io.netty.channel.epoll.Epoll.:743)
at org.apache.pulsar.client.impl.PulsarClientImpl.(Nat
浏览 18提问于2022-09-24得票数 0
回答已采纳
1回答
但是有一件事我还没有真正理解，当你的微服务被前端应用程序消耗时，最佳实践/通用模式是什么？我如何获得概要文件创建的结果，然后在下一个屏幕上使用它呢？
干杯
浏览 4提问于2022-03-30得票数 1
下面是我将脉冲星作为独立版本运行在坞-组合中的配置： image: apachepulsar/pulsar:2.6.0 - 8080:8080- 6650:6650 PULSAR_MEM: " -Xms512m -Xmx512m -XX:MaxDirectMemorySize=1g"conf/standalone.conf && bin/pulsar st
浏览 8提问于2022-08-18得票数 0
回答已采纳
1回答
我正在构建一个处理Apache Pulsar的GO应用程序。Go客户端需要C++库，正如Pulsar文档所要求的( Kafka btw也是如此)。 我想把所有这些都打包到一个容器中，尽可能小。/app"] 使用此命令会使构建失败，从而查找缺少的符号 /go/pkg/mod/github.com/apache/pulsar/pulsar-client-go@v0.0.0-20200118070759-
浏览 16提问于2020-01-18得票数 4
Apache pulsar通过分层存储减载器提供了一个非常有趣的架构。 我想知道如何从另一个应用程序进行交互式查询？我的意思是直接查询键值系统/“数据库”，而不是使用pulsar-sql，后者在底层使用Presto。 在@sijieg中，在twitter上，has posted以下模式： ? 我们如何访问这些状态存储/段阅读器并访问数据，就像Flink-Pulsar或Spark-Pulsar一样。
浏览 17提问于2020-04-07得票数 2
服务：NAME TYPE CLUSTER-IP EXTERNAL-IP PORT一些命令的输出如下："persistent://apache/pulsar&#
浏览 29提问于2022-01-27得票数 0
1回答
我已经建立了一个玩具示例，在这个示例中，生产者正在记录单个消息，并且在Pulsar服务器上订阅了同一个主题并侦听消息。5-1] INFO org.apache.pulsar.client.impl.ConsumerImplpackage com.pulsar_logging;
import org.apa
浏览 5提问于2020-06-24得票数 3
回答已采纳
我有一个LucidWorksFusion5 kubernetes安装安装在AWS 上，目前该服务之一，连接器经典REST服务，正在经历一次中断。Pulsar topic persistent://uat/_logs/system_logs at: pulsar://uat-pulsar-broker:6650 org.apache.pulsar.client.api.PulsarClientExceptionc
浏览 9提问于2022-01-07得票数 0
回答已采纳
我使用Apache Pulsar Python客户端来连接我的微服务。我想创建Key_Shared消费者，如下所示：consumer = client.subscribe('my-topic', 'consume-id&#x
浏览 13提问于2020-06-05得票数 1
pulsar管理器pulsar manager pulsar-LOG4J2-appender applog-json已连接到位于org.apache.pulsar.client的主题。(ProducerBuilderImpl.java:93) at org.apache.pulsar.log4j2.appender.PulsarManager.startup(PulsarManager.java:127) at org.apache.pulsa
浏览 3提问于2021-05-15得票数 1
我们在Pulsar客户端应用程序中看到了这个异常：
连接到代理的错误: org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException: java.util.concurrent.CompletionException: org.apache.pulsar.shade.io.netty.channel.AbstractChannel$尽管测试了不同的客户端设置，我们仍然无法找到复制它的方
浏览 1提问于2021-07-27得票数 0
1回答
安装似乎进行得很顺利，但是最后当我尝试获取HTTP代理URL和二进制代理URL时...我收到一条错误消息，指出我没有指定有效的服务： xyz-MBP:pulsar xyz$ kubectl get services-n pulsar –-url
❌ Exiting due to MK_USAGE: You must specify a service name 我用来显示服务的命令有什么地方做错了吗？为什么代理不显示为服务？ 以下是我将Pulsar安装到Minikube中所做的工作：
浏览 36提问于2021-10-19得票数 0
回答已采纳
zookeeper
starting zookeeper, logging to /home/host1/apache-pulsar-2.4.0/-2.4.0/lib/org.apache.pulsar-pulsar-zookeeper-utils-2.4.0.jar!/META-INF/aop.xml
[AppClassLoader@27c170f0] info usin
浏览 123提问于2019-09-02得票数 0
脉冲星客户端版本: 2.10，脉冲星服务器版本: 2.10，安装类型:独立(非码头)，操作系统: Ubuntu 20.04.4 LTSprivate static void consumeFromPulsarAsyncorg/apache/pulsar/shade/com/google/common/primitives/Ints at org.apache.pulsar.shade.com.goog
浏览 3提问于2022-05-10得票数 1
2回答
我在我的本地机器上运行apache-pulsar单机版，作为队列系统的docker容器，并将1000个作业推送到一个主题(假设是“demo”)。但如果我用更多的消费者(2或4个消费者)做同样的1000个作业测试，总吞吐量保持不变，大约80秒。我不确定我是否遗漏了一些所需的配置，或者是否需要多个pulsar brokers，或者我应该如何做，以便如果我增加消费者，消费吞吐量也应该增加(例如在2个消费者的情况下大约40-45秒)。Docker图像: apachepulsar/pulsar 消费选项：
浏览 26提问于2019-12-18得票数 2
雅虎开发了Pulsar，pub-sub消息系统，并使其开源。它现在是Apache的孵化项目。因为Kafka也用于相同的目的。想知道，卡夫卡相对于脉冲星的主要正负点。
浏览 1提问于2017-09-05得票数 56
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
