The docs say
"This exception indicates that the broker received an unexpected sequence
number from the producer, which means that data may have been lost. If the
producer is configured for idempotence only (i.e. if enable.idempotence is
set and no transactional.id is configured), it is possible to
Hi,
I'm trying to write a very basic Kafka streams consumer in Java.
Once I add a KTable, I see a message in the server log that I have been
unsubscribed from all topics.
Doing the same with a KStream instead of KTable works fine for me.
I'm using Kafka version 3.2.0 (kafka_2.13-3.2.0) and am r
Hi all,
Can anyone tell me in detail what exactly happens when I stop kafka using
kafka-stop script in /bin?
Doest it releases session or files or what cleanup operations?
Regards,
Sunil.