Разница между опросом и потреблением в библиотеке Kafka Confluent - PullRequest
0 голосов
/ 26 апреля 2018

Примеры github page для библиотеки Confluent Kafka содержат два метода, а именно опрос и потребление.В чем разница между ними?

Я посмотрел на реализацию Consumer в библиотеке Confluent Kafka здесь и чувствую, что они функционально одинаковы и отличаются только тем, чтоони вернулись.

Вызов Poll () потребляет (), чтобы увидеть, есть ли готовое сообщение для получения, и, если да, вызывает событие OnMessage.Принимая во внимание, что он потребляет, сохраняет сообщение в одном из его параметров и возвращает логическое значение.Я чувствую разницу в реализации, и функционально они одинаковы https://github.com/confluentinc/confluent-kafka-dotnet/blob/master/src/Confluent.Kafka/Consumer.cs

1 Ответ

0 голосов
/ 13 июня 2018

Вы правы.https://github.com/confluentinc/confluent-kafka-dotnet/blob/3f48e8944242abf631ea8d2cd5698f6e149e0731/src/Confluent.Kafka/Consumer.cs#L1147

Poll совпадает с Consume, просто предоставьте сообщение с другой семантикой.Consume вернет сообщение в параметре out, тогда как Poll вернет ноль и вызовет событие OnMessage.

Редактировать: в v1 остался только Consume вызов, больше нет путаницы.

...