[
https://issues.apache.org/jira/browse/KAFKA-14813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17757252#comment-17757252
]
Nicola Stringari commented on KAFKA-14813:
------------------------------------------
Sure, here is a couple of logs.
Thank you in advance!
Hope this can provide some clarity, we will be available to provide further
explanation if needed.
------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
org.springframework.kafka.listener.ListenerExecutionFailedException: Listener
failed; nested exception is
org.springframework.transaction.CannotCreateTransactionException: Could not
create Kafka transaction; nested exception is
org.apache.kafka.common.errors.TimeoutException: Timeout expired after
60000milliseconds while awaiting InitProducerId
at
org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:2113)
at
org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListenerInTx(KafkaMessageListenerContainer.java:1863)
at
org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1809)
at
org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1531)
at
org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1178)
at
org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1075)
at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at java.base/java.lang.Thread.run(Thread.java:829)
Caused by: org.springframework.transaction.CannotCreateTransactionException:
Could not create Kafka transaction; nested exception is
org.apache.kafka.common.errors.TimeoutException: Timeout expired after
60000milliseconds while awaiting InitProducerId
at
org.springframework.kafka.transaction.KafkaTransactionManager.doBegin(KafkaTransactionManager.java:162)
at
org.springframework.transaction.support.AbstractPlatformTransactionManager.startTransaction(AbstractPlatformTransactionManager.java:400)
at
org.springframework.transaction.support.AbstractPlatformTransactionManager.getTransaction(AbstractPlatformTransactionManager.java:373)
at
org.springframework.transaction.support.TransactionTemplate.execute(TransactionTemplate.java:137)
at
org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListenerInTx(KafkaMessageListenerContainer.java:1837)
... 7 common frames omitted
Caused by: org.apache.kafka.common.errors.TimeoutException: Timeout expired
after 60000milliseconds while awaiting InitProducerId
-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
Transaction rolled back
org.springframework.transaction.CannotCreateTransactionException: Could not
create Kafka transaction; nested exception is
org.apache.kafka.common.errors.TimeoutException: Timeout expired after
60000milliseconds while awaiting InitProducerId
at
org.springframework.kafka.transaction.KafkaTransactionManager.doBegin(KafkaTransactionManager.java:162)
at
org.springframework.transaction.support.AbstractPlatformTransactionManager.startTransaction(AbstractPlatformTransactionManager.java:400)
at
org.springframework.transaction.support.AbstractPlatformTransactionManager.getTransaction(AbstractPlatformTransactionManager.java:373)
at
org.springframework.transaction.support.TransactionTemplate.execute(TransactionTemplate.java:137)
at
org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListenerInTx(KafkaMessageListenerContainer.java:1837)
at
org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1809)
at
org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1531)
at
org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1178)
at
org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1075)
at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at java.base/java.lang.Thread.run(Thread.java:829)
Caused by: org.apache.kafka.common.errors.TimeoutException: Timeout expired
after 60000milliseconds while awaiting InitProducerId
> Timeout Exception causes data loss
> -----------------------------------
>
> Key: KAFKA-14813
> URL: https://issues.apache.org/jira/browse/KAFKA-14813
> Project: Kafka
> Issue Type: Bug
> Components: clients
> Affects Versions: 2.6.3
> Reporter: Nicola Stringari
> Priority: Major
>
> Hello everyone, I wanted to ask some information about a bug we encountered
> while using Apache Kafka clients.
> In our project that uses Kafka Clients at version 2.6.3, we often encounter
> this exception : _org.apache.kafka.common.errors.TimeoutException : Timeout
> expired after 60000milliseconds while awaiting for initProducerId..._
> By looking at the logs, we witnessed the application trying to execute the
> initProducerId operation and then failing after having waited the 60s
> interval without any response.
> What are the possible causes of this failure?
> We already tried to monitor the performance of the broker during the
> accidents and did not encounter any lag spike or abnormal use of memory which
> might explain why the request was not fulfilled in time.
>
> Thanks in advance, will be available to provide more information on our
> configuration if needed.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
