unsubscribed from all topics when adding a KTable

2022-05-27 Thread Meir Goldenberg
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

How it is safe to break message ordering but not idempotency after getting an OutOfOrderSequenceException?

2022-05-27 Thread Gabriel Giussi
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