Hello, Neha This is the error from server.log
[2014-12-22 23:53:25,663] WARN [KafkaApi-100] Fetch request with correlation id 1227732 from client ReplicaFetcherThread-0-100 on partition [perf_producer_p8_test,1] failed due to Leader not local for partition [perf_producer_p8_test,1] on broker 100 (kafka.server.KafkaApis) On Mon, Dec 22, 2014 at 3:50 PM, Sa Li <sal...@gmail.com> wrote: > > I restart the kafka server, it is the same thing, sometime nothing listed > on ISR, leader, I checked the state-change log > > [2014-12-22 23:46:38,164] TRACE Broker 100 cached leader info > (LeaderAndIsrInfo:(Leader:101,ISR:101,102,100,LeaderEpoch:0,ControllerEpoch:4),ReplicationFactor:3),AllReplicas:101,102,100) > for partition [perf_producer_p8_test,1] in response to UpdateMetadata > request sent by controller 101 epoch 4 with correlation id 138 > (state.change.logger) > > > > On Mon, Dec 22, 2014 at 2:46 PM, Sa Li <sal...@gmail.com> wrote: > >> Hi, All >> >> I created a topic with 3 replications and 6 partitions, but when I check >> this topic, seems there is no leader and isr were set for this topic, see >> >> bin/kafka-topics.sh --create --zookeeper 10.100.98.100:2181 >> --replication-factor 3 --partitions 6 --topic perf_producer_p6_test >> SLF4J: Class path contains multiple SLF4J bindings. >> SLF4J: Found binding in >> [jar:file:/etc/kafka/core/build/dependant-libs-2.10.4/slf4j-log4j12-1.6.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] >> SLF4J: Found binding in >> [jar:file:/etc/kafka/core/build/dependant-libs-2.10.4/slf4j-log4j12-1.7.6.jar!/org/slf4j/impl/StaticLoggerBinder.class] >> SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an >> explanation. >> SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory] >> Created topic "perf_producer_p6_test". >> >> root@precise64:/etc/kafka# bin/kafka-topics.sh --describe --zookeeper >> 10.100.98.100:2181 --topic perf_producer_p6_test >> SLF4J: Class path contains multiple SLF4J bindings. >> SLF4J: Found binding in >> [jar:file:/etc/kafka/core/build/dependant-libs-2.10.4/slf4j-log4j12-1.6.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] >> SLF4J: Found binding in >> [jar:file:/etc/kafka/core/build/dependant-libs-2.10.4/slf4j-log4j12-1.7.6.jar!/org/slf4j/impl/StaticLoggerBinder.class] >> SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an >> explanation. >> SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory] >> Topic:perf_producer_p6_test PartitionCount:6 >> ReplicationFactor:3 Configs: >> Topic: perf_producer_p6_test Partition: 0 Leader: none >> Replicas: 100,101,102 Isr: >> Topic: perf_producer_p6_test Partition: 1 Leader: none >> Replicas: 101,102,100 Isr: >> Topic: perf_producer_p6_test Partition: 2 Leader: none >> Replicas: 102,100,101 Isr: >> Topic: perf_producer_p6_test Partition: 3 Leader: none >> Replicas: 100,102,101 Isr: >> Topic: perf_producer_p6_test Partition: 4 Leader: none >> Replicas: 101,100,102 Isr: >> Topic: perf_producer_p6_test Partition: 5 Leader: none >> Replicas: 102,101,100 Isr: >> >> Is there a way to specifically set leader and isr in command line, it is >> strange when I create the topic with 5 partitions, it has leader and isr: >> root@precise64:/etc/kafka# bin/kafka-topics.sh --describe --zookeeper >> 10.100.98.100:2181 --topic perf_producer_p5_test >> SLF4J: Class path contains multiple SLF4J bindings. >> SLF4J: Found binding in >> [jar:file:/etc/kafka/core/build/dependant-libs-2.10.4/slf4j-log4j12-1.6.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] >> SLF4J: Found binding in >> [jar:file:/etc/kafka/core/build/dependant-libs-2.10.4/slf4j-log4j12-1.7.6.jar!/org/slf4j/impl/StaticLoggerBinder.class] >> SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an >> explanation. >> SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory] >> Topic:perf_producer_p5_test PartitionCount:5 >> ReplicationFactor:3 Configs: >> Topic: perf_producer_p5_test Partition: 0 Leader: 102 >> Replicas: 102,100,101 Isr: 102,100,101 >> Topic: perf_producer_p5_test Partition: 1 Leader: 102 >> Replicas: 100,101,102 Isr: 102,101 >> Topic: perf_producer_p5_test Partition: 2 Leader: 101 >> Replicas: 101,102,100 Isr: 101,102,100 >> Topic: perf_producer_p5_test Partition: 3 Leader: 102 >> Replicas: 102,101,100 Isr: 102,101,100 >> Topic: perf_producer_p5_test Partition: 4 Leader: 102 >> Replicas: 100,102,101 Isr: 102,101 >> >> >> Any ideas? >> >> thanks >> >> -- >> >> Alec Li >> > > > -- > > Alec Li > -- Alec Li
