github 示例 page对于 Confluent Kafka 库列出了两种方法,即 poll 和 consume。两者有什么区别。
我确实看过 Confluent Kafka 库中的 Consumer 实现 here ,并感觉它们在功能上是相同的,只是在它们返回的内容上有所不同。
Poll() 调用 consume() 以查看是否有消息准备好被拾取,如果是,则调用 OnMessage 事件。而消费,将消息保存在它的一个参数中,并返回一个 bool 值。我觉得区别在于实现,功能上它们是一样的 https://github.com/confluentinc/confluent-kafka-dotnet/blob/master/src/Confluent.Kafka/Consumer.cs
最佳答案
Poll
与Consume
相同,只是暴露不同语义的消息。 Consume
将在 out
参数中返回消息,而 Poll
返回 null 并将触发 OnMessage
事件。
编辑:在 v1 中只剩下 Consume
调用,不再有混淆。
关于c# - Kafka Confluent 库中 poll 和 consume 的区别,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/50036052/