You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Ray (JIRA)" <ji...@apache.org> on 2015/09/23 20:40:04 UTC

[jira] [Updated] (KAFKA-2577) one node of Kafka cluster cannot process produce request

     [ https://issues.apache.org/jira/browse/KAFKA-2577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Ray updated KAFKA-2577:
-----------------------
    Description: 
We had 3 nodes for kafka cluster, suddenly one node cannot accept produce r request, here is the log:
[2015-09-21 04:56:32,413] WARN [KafkaApi-0] Produce request with correlation id 9178992 from client  on partition [topic_name,3] failed due to Leader not local for partition [topic_name,3] on broker 0 (kafka.server.KafkaApis)

after restarting that node, it still cannot work and I saw different log:
[2015-09-21 20:38:16,791] WARN [KafkaApi-0] Produce request with correlation id 9661337 from client  on partition [topic_name,3] failed due to Topic topic_name either doesn't exist or is in the process of being deleted (kafka.server.KafkaApis)

it got fixed after rolling all the kafka nodes

  was:
We had 3 nodes for kafka cluster, suddenly one node cannot accept produce r request, here is the log:
[2015-09-21 04:56:32,413] WARN [KafkaApi-0] Produce request with correlation id 9178992 from client  on partition [topic_name,3] failed due to Leader not local for partition [topic_name,3] on broker 0 (kafka.server.KafkaApis)

after restarting that node, it still cannot work and I saw different log:
[2015-09-21 20:38:16,791] WARN [KafkaApi-0] Produce request with correlation id 9661337 from client  on partition [topic_name,3] failed due to Topic topic_name either doesn't exist or is in the process of being deleted (kafka.server.KafkaApis)


> one node of Kafka cluster cannot process produce request
> --------------------------------------------------------
>
>                 Key: KAFKA-2577
>                 URL: https://issues.apache.org/jira/browse/KAFKA-2577
>             Project: Kafka
>          Issue Type: Bug
>          Components: producer , replication
>    Affects Versions: 0.8.1.1
>            Reporter: Ray
>            Assignee: Jun Rao
>
> We had 3 nodes for kafka cluster, suddenly one node cannot accept produce r request, here is the log:
> [2015-09-21 04:56:32,413] WARN [KafkaApi-0] Produce request with correlation id 9178992 from client  on partition [topic_name,3] failed due to Leader not local for partition [topic_name,3] on broker 0 (kafka.server.KafkaApis)
> after restarting that node, it still cannot work and I saw different log:
> [2015-09-21 20:38:16,791] WARN [KafkaApi-0] Produce request with correlation id 9661337 from client  on partition [topic_name,3] failed due to Topic topic_name either doesn't exist or is in the process of being deleted (kafka.server.KafkaApis)
> it got fixed after rolling all the kafka nodes



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)