[KAFKA-16122] TransactionsBounceTest -- server disconnected before response was received

• Type: Test
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Assignee: Justine Olshan
• Reporter: Justine Olshan
• Created: 12/Jan/24 23:49
• Updated: 26/Jan/24 19:06
• Resolved: 26/Jan/24 19:06

Description

I noticed a ton of tests failing with 

 

Error  org.apache.kafka.common.KafkaException: Unexpected error in TxnOffsetCommitResponse: The server disconnected before a response was received.  

Stacktrace  org.apache.kafka.common.KafkaException: Unexpected error in TxnOffsetCommitResponse: The server disconnected before a response was received.  at app//org.apache.kafka.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler.handleResponse(TransactionManager.java:1702)  at app//org.apache.kafka.clients.producer.internals.TransactionManager$TxnRequestHandler.onComplete(TransactionManager.java:1236)  at app//org.apache.kafka.clients.ClientResponse.onComplete(ClientResponse.java:154)  at app//org.apache.kafka.clients.NetworkClient.completeResponses(NetworkClient.java:608)  at app//org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:600)  at app//org.apache.kafka.clients.producer.internals.Sender.maybeSendAndPollTransactionalRequest(Sender.java:457)  at app//org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:334)  at app//org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:249)  at java.base@21.0.1/java.lang.Thread.run(Thread.java:1583) 

The error indicates a network error which is retriable but the TxnOffsetCommit handler doesn't expect this. 

https://issues.apache.org/jira/browse/KAFKA-14417 addressed many of the other requests but not this one. 

Issue Links

• links to: GitHub Pull Request #15266