Boa tarde,
Nos meus testes eu consegui consumir as mensagens enviadas somente utilizando a chamada dentro de um laço (while(true)), tanto as novas quanto as antigas que estão esperando ser consumidas, porém eu não consegui consumir as mensagens fazendo uma única chamada (executando fora do laço) e sei que essas mensagens existem pois consigo vê-las pelo kafka executando o comando "bin/kafka-consumer-groups.sh --all-groups --bootstrap-server localhost:9092 --describe".
Qual poderia ser o problema desse cenário?