c# - Kafka Confluent 库中 poll 和 consume 的区别

Question

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

Answer 1

你是对的。 https://github.com/confluentinc/confluent-kafka-dotnet/blob/3f48e8944242abf631ea8d2cd5698f6e149e0731/src/Confluent.Kafka/Consumer.cs#L1147

Poll 与Consume 相同，只是暴露不同语义的消息。 Consume 将在 out 参数中返回消息，而 Poll 返回 null 并将触发 OnMessage 事件。

编辑:在 v1 中只剩下 Consume 调用，不再有混淆。