Hello All,
While using kafka streams application, we are intermittently getting
following exception and stream is closed. We need to restart the
application to get it working again and start processing. This exception is
observed in some of the labs which are being idle for some time but it is
not observed always. Any inputs appreciated here.
{"@timestamp":"2020-04-15T13:53:52.698+00:00","@version":"1","message":"stream-thread
[analytics-event-filter-StreamThread-1] Failed to commit stream task 2_14
due to the following
error:","logger_name":"org.apache.kafka.streams.processor.internals.AssignedStreamsTasks","thread_name":"analytics-event-filter-StreamThread-1","level":"ERROR","level_value":40000,"stack_trace":"org.apache.kafka.common.KafkaException:
Unexpected error in AddOffsetsToTxnResponse: The producer attempted to use
a producer id which is not currently assigned to its transactional
id.\n\tat
org.apache.kafka.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler.handleResponse(TransactionManager.java:1406)\n\tat
org.apache.kafka.clients.producer.internals.TransactionManager$TxnRequestHandler.onComplete(TransactionManager.java:1069)\n\tat
org.apache.kafka.clients.ClientResponse.onComplete(ClientResponse.java:109)\n\tat
org.apache.kafka.clients.NetworkClient.completeResponses(NetworkClient.java:561)\n\tat
org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:553)\n\tat
org.apache.kafka.clients.producer.internals.Sender.maybeSendAndPollTransactionalRequest(Sender.java:425)\n\tat
org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:311)\n\tat
org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:244)\n\tat
java.base/java.lang.Thread.run(Unknown Source)\n"}
