You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "sriram (JIRA)" <ji...@apache.org> on 2014/06/13 15:50:01 UTC
[jira] [Updated] (KAFKA-1492) Getting error when sending producer
request at the broker end with a single broker
[ https://issues.apache.org/jira/browse/KAFKA-1492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
sriram updated KAFKA-1492:
--------------------------
Description:
Tried to run a simple example by sending a message to a single broker . Getting error
[2014-06-13 08:35:45,402] INFO Closing socket connection to /127.0.0.1. (kafka.network.Processor)
[2014-06-13 08:35:45,440] WARN [KafkaApi-1] Produce request with correlation id 2 from client on partition [samsung,0] failed due to Leader not local for partition [samsung,0] on broker 1 (kafka.server.KafkaApis)
[2014-06-13 08:35:45,440] INFO [KafkaApi-1] Send the close connection response due to error handling produce request [clientId = , correlationId = 2, topicAndPartition = [samsung,0]] with Ack=0 (kafka.server.KafkaApis)
OS- Windows 7 , JDK 1.7 , Scala 2.10
was:
Tried to run a simple example by sending a message to a single broker . Getting error
[2014-06-13 08:35:45,402] INFO Closing socket connection to /127.0.0.1. (kafka.network.Processor)
[2014-06-13 08:35:45,440] WARN [KafkaApi-1] Produce request with correlation id 2 from client on partition [samsung,0] failed due to Leader not local for partition [samsung,0] on broker 1 (kafka.server.KafkaApis)
[2014-06-13 08:35:45,440] INFO [KafkaApi-1] Send the close connection response due to error handling produce request [clientId = , correlationId = 2, topicAndPartition = [samsung,0]] with Ack=0 (kafka.server.KafkaApis)
> Getting error when sending producer request at the broker end with a single broker
> ----------------------------------------------------------------------------------
>
> Key: KAFKA-1492
> URL: https://issues.apache.org/jira/browse/KAFKA-1492
> Project: Kafka
> Issue Type: Bug
> Components: producer
> Affects Versions: 0.8.1.1
> Reporter: sriram
> Assignee: Jun Rao
>
> Tried to run a simple example by sending a message to a single broker . Getting error
> [2014-06-13 08:35:45,402] INFO Closing socket connection to /127.0.0.1. (kafka.network.Processor)
> [2014-06-13 08:35:45,440] WARN [KafkaApi-1] Produce request with correlation id 2 from client on partition [samsung,0] failed due to Leader not local for partition [samsung,0] on broker 1 (kafka.server.KafkaApis)
> [2014-06-13 08:35:45,440] INFO [KafkaApi-1] Send the close connection response due to error handling produce request [clientId = , correlationId = 2, topicAndPartition = [samsung,0]] with Ack=0 (kafka.server.KafkaApis)
> OS- Windows 7 , JDK 1.7 , Scala 2.10
--
This message was sent by Atlassian JIRA
(v6.2#6252)