[watermill-kafka] why message doesn't resend when consumer group don't send ACK

[suhoangson]

when consumer group got message from kafka topic and process, some error happen then consumer don't call msg.Ack() , why this message don't resend again, just resend when i restart consumer

[OneCricketeer]

The consumer will continue to seek forward and poll within the runtime of the same application. When you restart, you lose local state, and so Kafka offset state will be fetched from the consumer group.

You can open an issue with the Sarama client repo if you think this is a problem with the client implementation.