[
https://issues.apache.org/jira/browse/KAFKA-1492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14030787#comment-14030787
]
sriram commented on KAFKA-1492:
-------------------------------
When running consumer.
Broker Console:
[2014-06-13 11:03:43,075] WARN [KafkaApi-1] Offset request with correlation id
0 from client
console-consumer-28645-ConsumerFetcherThread-console-consumer-28645_TXCDTL0249057V-1402675420035-8dbe6843-0-1
on partition [samsung,0] failed due to Leader not local for partition
[samsung,0] on broker 1 (kafka.server.KafkaApis)
[2014-06-13 11:03:43,109] INFO Closing socket connection to /135.70.254.3.
(kafka.network.Processor)
Client Console:
2014-06-13 11:03:43,078] WARN
[console-consumer-28645_TXCDTL0249057V-1402675420035-8dbe6843-leader-finder-thread],
Failed to add leader for partition [samsung,0]; will retry
(kafka.consumer.ConsumerFetcherManager$LeaderFinderThread)
afka.common.NotLeaderForPartitionException
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
at
sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57)
at
sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
at java.lang.reflect.Constructor.newInstance(Constructor.java:526)
at java.lang.Class.newInstance(Class.java:374)
at kafka.common.ErrorMapping$.exceptionFor(ErrorMapping.scala:70)
at
kafka.consumer.SimpleConsumer.earliestOrLatestOffset(SimpleConsumer.scala:147)
at
kafka.consumer.ConsumerFetcherThread.handleOffsetOutOfRange(ConsumerFetcherThread.scala:60)
at
kafka.server.AbstractFetcherThread.addPartition(AbstractFetcherThread.scala:175)
at
kafka.server.AbstractFetcherManager.addFetcher(AbstractFetcherManager.scala:80)
at
kafka.consumer.ConsumerFetcherManager$LeaderFinderThread$$anonfun$doWork$7.apply(ConsumerFetcherManager.scala:97)
at
kafka.consumer.ConsumerFetcherManager$LeaderFinderThread$$anonfun$doWork$7.apply(ConsumerFetcherManager.scala:93)
at
scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
at
scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
at scala.collection.Iterator$class.foreach(Iterator.scala:772)
at
scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157)
at
scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190)
at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45)
at scala.collection.mutable.HashMap.foreach(HashMap.scala:95)
> 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)
