[
https://issues.apache.org/jira/browse/KAFKA-5296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16036542#comment-16036542
]
Abhisek Saikia commented on KAFKA-5296:
---------------------------------------
The issue gets resolved automatically after rebooting one of the two
controllers. The issue happens when there are more than one controllers in the
cluster, so I think the issue to be resolved is how to avoid having more than
one controllers in the cluster?
> Unable to write to some partitions of newly created topic in 10.2
> -----------------------------------------------------------------
>
> Key: KAFKA-5296
> URL: https://issues.apache.org/jira/browse/KAFKA-5296
> Project: Kafka
> Issue Type: Bug
> Affects Versions: 0.10.2.0
> Reporter: Abhisek Saikia
>
> We are using kafka 10.2 and the cluster was running fine for a month with 50
> topics and now we are having issue in producing message by creating new
> topics. The create topic command is successful but producers are throwing
> error while writing to some partitions.
> Error in producer-
> java.util.concurrent.ExecutionException:
> org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for
> [topic1]-8: 30039 ms has passed since batch creation plus linger time
> at
> org.apache.kafka.clients.producer.internals.FutureRecordMetadata.valueOrError(FutureRecordMetadata.java:70)
> ~[kafka-clients-0.10.2.0.jar:na]
> at
> org.apache.kafka.clients.producer.internals.FutureRecordMetadata.get(FutureRecordMetadata.java:57)
> ~[kafka-clients-0.10.2.0.jar:na]
> at
> org.apache.kafka.clients.producer.internals.FutureRecordMetadata.get(FutureRecordMetadata.java:25)
> ~[kafka-clients-0.10.2.0.jar:na]
> On the broker side, I don't see any topic-parition folder getting created for
> the broker who is the leader for the partition.
> While using 0.8 client, the write used to hang while it starts writing to the
> partition having this issue. With 10.2 it resolved the the producer hang issue
>
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
