Я установил offset.store.method для брокера на потребителе, однако он не работает в сценарии ниже.
Брокер / потребитель не работает, производитель поставил в очередь 4 сообщения в своей очереди.После того, как появился брокер, а затем появился потребитель, потребитель получил 4 сообщения, но все они просто дублируют последнее сообщение, созданное производителем.В чем может быть проблема?
использует клиентскую библиотеку c ++ librdkafka для потребительского приложения
Редактировать: Это то, что произошло - брокер и потребитель не работают ... после того, как этот производитель поставил в очередь 4 сообщения 1 2 3 4... затем пришли брокер и потребитель ... потребитель получил четыре копии 4, то есть 4 4, 4 4 вместо 1 2 3 4