合流kafka库的github示例页面列出了两种方法，即poll和consume。这两者有什么区别。
我确实在这里查看了融合kafka库中的消费者实现，感觉它们在功能上是相同的，只是在返回的内容方面有所不同。
poll（）调用consume（），查看是否有消息可以接收，如果有，则调用onmessage事件。然而，consume将消息保存在它的一个参数中，并返回一个布尔值。我觉得不同之处在于实现上，功能上是一样的https://github.com/confluentinc/confluent-kafka-dotnet/blob/master/src/confluent.kafka/consumer.cs
1条答案
按热度按时间iswrvxsc1#
你是对的。https://github.com/confluentinc/confluent-kafka-dotnet/blob/3f48e8944242abf631ea8d2cd5698f6e149e0731/src/confluent.kafka/consumer.cs#l1147
Poll与相同Consume，只需公开具有不同语义的消息。Consume将在中返回消息out参数，鉴于Poll返回null并将开火OnMessage事件。编辑：在v1中只有
Consume向左打电话，不再混乱。