1回答
.*;import org.apache.beam.io.pulsar.*;import org.apache.pulsar.client.api.*;
import org.apache.pulsar<
浏览 10提问于2022-10-03得票数 1
我正在尝试为Apache Pulsar设置一个异步消费者，但我的问题是只收到一条消息，除非我重新启动Spring Boot应用程序，否则没有其他消息。ApplicationReadyEvent.class)
Consumer consumer = this.pulsarClient.newConsumerDocs: Pulsar Docs：https://pulsar.<em
浏览 111提问于2021-04-20得票数 1
回答已采纳
<code>F 211</code>import org.apache.pulsar.client.api.PulsarClient;
PulsarClient使用者’抛出的异常；嵌套异常是已关闭的org.apache.pulsar.client.api.P
浏览 1提问于2021-07-27得票数 0
1回答
import java.util.concurrent.TimeUnit;
import org.apache.pulsar.client.api.Message;
import org.apache.pulsar.client.api
浏览 26提问于2019-03-13得票数 0
;
import org.apache.pulsar.client.api.Message;import org.apache.pulsar.client.api.MessageBuilder;
import o
浏览 344提问于2019-02-10得票数 1
import org.apache.pulsar.client.api.Producer;importorg.apache.pulsar.client.api.PulsarClientException;
p
浏览 4提问于2022-03-02得票数 1
1回答
5-1] INFO org.apache.pulsar.client.impl.ConsumerImplpackage com.pulsar_logging;
import
浏览 5提问于2020-06-24得票数 3
回答已采纳
我有一个Java客户端客户端正在接收Pulsar (v2.10.0) AVRO消息(雇员)，如下所示：importorg.apache.pulsar.client.api.Message;
import org.apache.pulsar.cli
浏览 2提问于2022-05-31得票数 2
然而，我实际上想(集成-)测试功能(实现org.apache.pulsar.functions.api.Function)。如何在嵌入式设置中注册函数？import org.apache.pulsar.PulsarStandaloneBuilderimportorg.apache.
浏览 26提问于2019-06-09得票数 1
回答已采纳
我的制片班就是这样import org.apache.pulsar.client.impl.schema.JSONSchema;
public static void main(String[] argsPulsa
浏览 3提问于2021-09-28得票数 1
回答已采纳
： .serviceUrl(config.get("target"))(EventLoopUtil.java:46) at org
浏览 18提问于2022-09-24得票数 0
回答已采纳
client = PulsarClient.yml</include> </resource> </build>
正在显示的错误：
org.apache.pulsar.client.impl.MultiTopicsConsumerImpl：<em
浏览 3提问于2022-05-10得票数 1
pom.xml片段 <dependency> <artifactId>pulsar-client-original</artifactId> </dependency>
浏览 8提问于2022-01-07得票数 1
回答已采纳
我有一个Producer，它使用Apache作为Log4j2的一个附录来记录消息。
Consumer正在监听同一个Pulsar主题，并将接收到的消息写入日志文件。id: 0xb78fd850, L:/127.0.0.1:53782 - R:localhost/127.0.0.1:6650] Received a message from the server: org.apache.pulsar.common.api.proto.PulsarApiclass Cons
浏览 1提问于2020-06-26得票数 0
because ofCaused by: org.apache.pulsar.client.api.PulsarClientException$TimeoutException: 3 lookuprequ
浏览 24提问于2020-11-05得票数 2
回答已采纳
R:localhost/127.0.0.1:6651]] Connection handshake partitioned topic metadata:
org.apache.pulsar.client.api.PulsarC
浏览 162提问于2019-04-03得票数 1
org.apache.pulsar.client.api.PulsarClientException$ProducerBusyException: Producer with name 'pulsar-log4j2-appender-json_persistor4' is already connected to topic
at org.apache.pulsar.client.
浏览 6提问于2020-07-28得票数 1
回答已采纳
我使用cloudant-client-1.0.0.jar进行测试，检查到cloudant服务器的连接如下：
new test().getDb(&q
浏览 3提问于2016-03-27得票数 1
回答已采纳
/go-examples/exclamationFunc /pulsar/examples/go-examples/exclamationFunc.go运行在"github.com/apache/pulsar/pulsar-function-go/examples/test/producer.go:30:6: main redeclar
浏览 4提问于2020-01-23得票数 0
线程"main“中的异常-- java.net.URLClassLoader.findClass(URLClassLoader.java:381)：org/apache/http/ConnectionReuseStrategyat com.wang.testMaven.App.main(App.java:16) --由: java.lang.ClassNotFoundException: org.apache.h
浏览 1提问于2016-04-20得票数 4
回答已采纳
云服务器
ICP备案
云点播
对象存储
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号