Hi Team,

I am facing an issue in a clustered Kafka environment,

org.apache.kafka.common.KafkaException: Cannot perform send because at least 
one previous transactional or idempotent request has failed with errors.
at 
org.apache.kafka.clients.producer.internals.TransactionManager.failIfNotReadyForSend(TransactionManager.java:279)
 ~[kafka-clients-2.0.1.jar:?]

Brokers - 3
Replication factor - 3
ISR - 2

Kafka version - kafka_2.12-2.5.0

Please help me to solve this issue.

Regards,
Indu V

This electronic mail (including any attachment thereto) may be confidential and 
privileged and is intended only for the individual or entity named above. Any 
unauthorized use, printing, copying, disclosure or dissemination of this 
communication may be subject to legal restriction or sanction. Accordingly, if 
you are not the intended recipient, please notify the sender by replying to 
this email immediately and delete this email (and any attachment thereto) from 
your computer system...Thank You.

Reply via email to