0
respostas

Consumer no Windows (kafka-console-consumer.bat)

Rodei o seguir no Windows para criar um consumidor:

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic LOJA_NOVO_PEDIDO --from-beginning

Porém não funcionou, nenhuma mensagem estava sendo captada pelo consumer.

Após uma pesquisa, encontrei a seguinte adição:

kafka-console-consumer.bat --bootstrap-server localhost:9092 --from-beginning --topic LOJA_NOVO_PEDIDO --partition 0

Dessa maneira funcionou, o consumer identificou todas a mensagem vindas do producer.

Alguém poderia me explicar porque isso acontece no Windows?