如何使用Akka Streams持续使用Apache Pulsar中的消息并打印每条消息？
下面是我从库中找到的示例代码。如何打印消费的消息，而不是将消息发布到另一个主题？
浏览 7提问于2020-05-22得票数 0
1回答
我正在尝试将Apache设置为log4j2的一个附录。这里没有太多的文档，但是我在这里找到了一些例子。我已经建立了一个玩具示例，在这个示例中，生产者正在记录单个消息，并且在Pulsar服务器上订阅了同一个主题并侦听消息。消费者收到了一些东西，但没有收到我所期望的信息：Message received: 18:05:27.510 [pulsar-client-io-;
import org.<em
浏览 5提问于2020-06-24得票数 3
回答已采纳
1回答
我试图在ubuntu上安装节点js客户端的脉冲星客户机。我得到以下错误：compilation/obj.target/Pulsar/src/addon.o] Error 1 Pulsar Node.js客户端库基于C++客户
浏览 3提问于2020-01-24得票数 1
回答已采纳
雅虎开发了Pulsar，pub-sub消息系统，并使其开源。它现在是Apache的孵化项目。因为Kafka也用于相同的目的。想知道，卡夫卡相对于脉冲星的主要正负点。
浏览 1提问于2017-09-05得票数 56
1回答
我在Pulsar中有一个持续的话题，它有200条信息。前100条消息被确认，但其余的消息不被确认。我使用WebSockets连接到Pulsar主题来读取它们。这里是我的问题：，当我创建一个新的阅读器时，它似乎没有获取未被确认的100条消息。它将只获取在使读取器生成后排队的新消息。
如何使用读取器检索旧的未确认<
浏览 1提问于2019-11-16得票数 2
我认为这是因为我的PropertyConfigurator制作不好，但是即使我使用defaultConfigurator，也会得到同样长的错误.当我试图让我的PulsarClient变成这样的时候，它就坏了:743) at org.apache.pulsar.client.impl.Pulsa
浏览 18提问于2022-09-24得票数 0
回答已采纳
我有一个Java客户端客户端正在接收Pulsar (v2.10.0) AVRO消息(雇员)，如下所示：import现在，我试图通过Websocket 或REST 生成消息时获得相同的结果。该消息被使用者接受和接收，但抛出一个异常：
线程"main“org.apache.pulsar.shade.com.googl
浏览 2提问于2022-05-31得票数 2
1回答
我是新来Pulsar的！ 现在，我正在尝试用Scala实现这些代码( https://flink.apache.org/2019/05/03/pulsar-flink.html )。我如何在Scala中实现它们？我应该在哪里检查？
浏览 20提问于2020-07-28得票数 0
回答已采纳
我正在尝试为Apache Pulsar设置一个异步消费者，但我的问题是只收到一条消息，除非我重新启动Spring Boot应用程序，否则没有其他消息。不幸的是，关于在脉冲星上使用CompletableFuture的文档不是很好，我还是个新手。，但我不确定如何做到这一点。我认为这是导致问题的原因。Doc for receieveAsync()：https://pulsar.
浏览 111提问于2021-04-20得票数 1
回答已采纳
我正在使用Apache Pulsar，并试图部署一个Pulsar函数，但我得到了这个错误： org.apache.pulsar.broker.web.RestException: Policies notfound for myTenant/myNamespace namespace 我已经检查了函数中的代码，一切看起来都很正常。我使用的是Pulsar 2.6.0，但我尝试了其他版本，并获得了相同的
浏览 152提问于2021-04-13得票数 1
在Pulsar Python客户端中，有订阅者选项unacked_messages_timeout_ms来设置未确认消息重新发送的时间间隔。 与Pulsar Go客户端相当的是什么？) 戈朗 go_consumer, err := client.Subscribe( Topic: "my-topic",SubscriptionName: "go-subscriber",
Typ
浏览 43提问于2021-08-31得票数 0
回答已采纳
我正在为Apache使用Java用户，而我的应用程序不会启动。脉冲星令牌是正确的。我们可以使用telnet和curl命令命中目标SSL端口(6651)，所以它不是防火墙或网络问题角色在Pulsar 中有足够的权限，我们正在为正确的Pulsar集群命中正确的端点，我们在这个环境中使用正确的信任证书‘使用者’的错误；嵌套异常是
浏览 1提问于2021-07-27得票数 0
我在Go代码中引用了一个包为：但是，在构建用于设置集成测试的坞映像时，我需要包括对该库的一些本地更改。但是，当我试图通过运行以下行来构建引用github.com/apache/pulsar/pulsar-function-go/pf的文件时：
RUN go bu
浏览 4提问于2020-01-23得票数 0
Apache pulsar通过分层存储减载器提供了一个非常有趣的架构。 我想知道如何从另一个应用程序进行交互式查询？我的意思是直接查询键值系统/“数据库”，而不是使用pulsar-sql，后者在底层使用Presto。 在@sijieg中，在twitter上，has posted以下模式： ? 看起来我可以访问State-store (甚至是Segment-reader)并直接访问博彩公司中的数据(根据Metastore ?
浏览 17提问于2020-04-07得票数 2
Apache有一个TTL特性，如官方文档的主题所示。但是，我无法确定在配置中设置了多久一次这样的检查。使用具有自定义命名空间的标准bin/pulsar standalone命令，配置为5秒bin/pulsar-admin namespaces set-message-ttl public/ttl-test--messageTTL 5的ttl。我可以看到，消息只有在设置间隔后才过期，下面的日志消息<
浏览 0提问于2019-03-20得票数 1
回答已采纳
在我的Pulsar消费者/生产者中，当我试图连接到Pulsar时，我会收到以下错误消息：
org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException： java.util.concurrent.CompletionException: org.apache.pulsar.shade.io.netty.channel.A
浏览 1提问于2020-06-11得票数 0
为了进行测试，我设法运行了一个嵌入式独立pulsar服务器和客户端。我还可以发送和接收消息。然而，我实际上想(集成-)测试功能(实现org.apache.pulsar.functions.api.Function)。如何在嵌入式设置中注册函数？import org.apache.pulsar.PulsarStandaloneBuilderim
浏览 26提问于2019-06-09得票数 1
回答已采纳
我试图通过java执行apache pulsar生产者和消费者程序，我在GCP虚拟机上安装了apache-pulsar standalone，并在独立模式下启动了集群。，这是显而易见的，因为pulsar没有安装在windows机器上。;
import org.apache.pulsar.client.api.
浏览 344提问于2019-02-10得票数 1
2回答
我目前正在尝试使用Helm将Pulsar安装到Minikube集群上。一切似乎都安装正确，但是pod没有在正确的名称空间下注册。我运行以下脚本将Pulsar安装到Minikube上： #!/examples/values-minikube.yaml pulsar-mini apache/pulsar
sleep-o name 取而代之的是，Pod
浏览 37提问于2021-10-18得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
