You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/11/20 18:39:01 UTC
[jira] [Comment Edited] (KAFKA-6237) stream stopped working after
exception: Cannot execute transactional method because we are in an error
state
[ https://issues.apache.org/jira/browse/KAFKA-6237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16259618#comment-16259618 ]
Matthias J. Sax edited comment on KAFKA-6237 at 11/20/17 6:38 PM:
------------------------------------------------------------------
Thanks for reporting this. It is a duplicate and the issue is fixed in {{0.11.0.1}}. At least for the Streams API part.
Not sure if this is a broker issue, too.
was (Author: mjsax):
Thanks for reporting this. It is a duplicate and the issue is fixed in {{0.11.0.1}}.
> 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
> Components: core, streams
> 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)