[ https://issues.apache.org/jira/browse/KAFKA-6237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16259176#comment-16259176 ]
DHRUV BANSAL commented on KAFKA-6237: ------------------------------------- Also when I see the state of the corresponding consumer group it is saying: Warning: Consumer group is *+rebalancing+*. > stream stopped working after exception: Cannot execute transactional method > because we are in an error state > ------------------------------------------------------------------------------------------------------------ > > Key: KAFKA-6237 > URL: https://issues.apache.org/jira/browse/KAFKA-6237 > Project: Kafka > Issue Type: Bug > Reporter: DHRUV BANSAL > Priority: Critical > Attachments: nohup.out > > > 017-11-19 07:52:44,673 > [project_logs_stream-a30ea242-3c9f-46a9-a01c-51903bd40ca5-StreamThread-1] > ERROR: org.apache.kafka.streams.processor.internals.StreamThread - > stream-thread > [orion_logs_stream-a30ea242-3c9f-46a9-a01c-51903bd40ca5-StreamThread-1] > Failed while closing StreamTask 0_1: > org.apache.kafka.common.KafkaException: Cannot execute transactional method > because we are in an error state > at > org.apache.kafka.clients.producer.internals.TransactionManager.maybeFailWithError(TransactionManager.java:524) > at > org.apache.kafka.clients.producer.internals.TransactionManager.beginAbort(TransactionManager.java:198) > at > org.apache.kafka.clients.producer.KafkaProducer.abortTransaction(KafkaProducer.java:598) > at > org.apache.kafka.streams.processor.internals.StreamTask.close(StreamTask.java:434) > at > org.apache.kafka.streams.processor.internals.StreamThread.shutdownTasksAndState(StreamThread.java:1086) > at > org.apache.kafka.streams.processor.internals.StreamThread.shutdown(StreamThread.java:1041) > at > org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:538) > Caused by: org.apache.kafka.common.KafkaException: Unexpected error in > AddOffsetsToTxnResponse: The server experienced an unexpected error when > processing the request > at > org.apache.kafka.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler.handleResponse(TransactionManager.java:978) > at > org.apache.kafka.clients.producer.internals.TransactionManager$TxnRequestHandler.onComplete(TransactionManager.java:648) > at > org.apache.kafka.clients.ClientResponse.onComplete(ClientResponse.java:101) > at > org.apache.kafka.clients.NetworkClient.completeResponses(NetworkClient.java:454) > at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:446) > at > org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:206) > at > org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:162) > at java.lang.Thread.run(Thread.java:745) > Also when I see the state of the corresponding consumer group it is saying: > Warning: Consumer group is rebalancing. -- This message was sent by Atlassian JIRA (v6.4.14#64029)