当前位置: 首页 > 知识库问答 >
问题:

Kafka合流图书馆民意测验与消费的差异

强保臣
2023-03-14

我在这里查看了Confluent Kafka库中的消费者实现,感觉它们在功能上是相同的,只是在返回的内容方面有所不同。

Poll()调用consumer()来查看是否有消息准备好要拾取,如果是,则调用OnMessage事件。versour,consumer,将消息保存在它的一个参数中,并返回一个布尔值。我觉得不同之处在于实现上,功能上是相同的https://github.com/confluentinc/confluent-kafka-dotnet/blob/master/src/confluent.kafka/consumer.cs

共有1个答案

宇文元明
2023-03-14

你是正确的.https://github.com/confluentinc/confluent-kafka-dotnet/blob/3f48e8944242abf631ea8d2cd5698f6e149e0731/src/confluent.kafka/consumer.cs#l1147

pollconsum相同,只是公开不同语义的消息。consumer将在out参数中返回消息,而poll返回null并将激发onmessage事件。

编辑:在v1中,只剩下consume调用,不再混乱。

 类似资料:
  • 我刚接触Kafka,正在为我的新应用程序尝试一些小用例。用例基本上是Kafka制作人- 当消费时(步骤2),下面是步骤的顺序...1.消费者。轮询(1.0)1. a.产生多个主题(多个水槽代理正在监听)1.b。产生。轮询()2。每25个msgs刷新()3。提交()每个msgs(asynchCommit=false) 问题1:这个动作顺序对吗!?! 问题2:这会导致数据丢失吗?因为刷新是每25毫秒一

  • 我正在尝试使用PollRich获得JPA实体 但是在那之后,尽管表包含数百行,但我只得到一行。如何获取所有行?我想要像往常一样的polEnrich行为,它给我所有的表行。

  • 我正试图按照GitHub的建议设置测试 其中StreamProcessor设置为 -->line从不使用在我看来应该在主题“output”上的消息,因为@StreamProcessor有@Sendto(“output”) 我希望能够测试流处理的消息。

  • 我最近开始学习Kafka,最后就问了这些问题。 > 消费者和流的区别是什么?对我来说,如果任何工具/应用程序消费来自Kafka的消息,那么它就是Kafka世界中的消费者。 流与Kafka有何不同?为什么需要它,因为我们可以使用消费者API编写自己的消费者应用程序,并根据需要处理它们,或者将它们从消费者应用程序发送到Spark? 我做了谷歌对此,但没有得到任何好的答案。抱歉,如果这个问题太琐碎了。

  • 我是一个PHP开发人员。我已经实现了贝宝移动图书馆IPN。以下是我在测试模式下收到的。 正如我看到的,有一个字段verify_sign,所以我猜测应该通过以下POST请求发送到https://www.sandbox.paypal.com/cgi-bin/webscr来验证它: 那么我如何验证贝宝移动图书馆的响应呢?我可以检查它的验证在沙箱模式或仅在现场。 谢谢你的任何建议。

  • 是否有一种方法以编程方式访问和打印使用者滞后偏移,或者说使用者读取的最后一条记录的偏移与某个生产者写入该使用者分区的最后一条记录的偏移之间的位置差。 要知道我的最终目标是将这个值发送到prometheus进行监视,我应该在上面添加哪些语句来得到滞后偏移值?