Re: What role plays transactional.id after KIP-447?

"I think we may overlooked it in documentation to emphasize that, in case 1), it should not expect ProducerFencedException. If so, we can fix the javadoc." IMHO that would be nice, I'm reviewing an existing codebase where we were only handling ProducerFencedException, because the javadoc and the m

Random continuous TimeoutException with Topic not present on one KafkaProducer out of many in multithreaded env

Hello Everyone, We are using Kafka 2.8.1 Broker/Client system in our prod env. Getting following exception randomly after 1 hour or so for one Realtime transfer from Kafka Producer to broker out of 5. (Rest 4 are working fine.) java.util.concurrent.ExecutionException: org.apache.kafka.common.e

Re: What role plays transactional.id after KIP-447?

I think "commitTransaction" should not throw CommitFailedException. Here admittedly we are overusing the term "commit" here, as we use it for two operations: committing the offsets (used for consumer, in either EOS or ALOS), and committing the transaction. The exception is meant for the former and