[testingTopic,9] resided on Broker-0 and Broker-2 at the beginning, and were planned to Broker-1 and Broker-2. Here are what I have found in controller.log on Broker-2 and server.log on Broker-1: controller.log on Broker-2: ************************************************** 2085 [2015-01-05 10:01:05,997] INFO [Controller 2]: Handling reassignment of partition [testingTopic,9] to new replicas 2,1 (kafka.controller.KafkaController) 2086 [2015-01-05 10:01:05,999] INFO [Controller 2]: New replicas 2,1 for partition [testingTopic,9] being reassigned not yet caught up with the leader (kafka.controller.KafkaController) 2087 [2015-01-05 10:01:06,001] DEBUG [Controller 2]: Updated path /brokers/topics/testingTopic with {"version":1,"partitions":{"34":[1,0],"12":[0,1],"8":[2,0],"19":[1,2],"23":[2,1],"4":[1,0],"15":[0,2],"11":[2,1],"9":[2,1,0],"33":[0,2],"22":[1,0],"26":[2,0],"13":[1,2],"24":[0,1],"35":[2,1],"16":[4,1,0],"5":[2,1],"10":[1,0],"21":[0,2],"32":[0,1,2],"6":[4,3,0,1],"1":[4,2,1],"17":[2,1],"25":[1,2],"14":[2,0],"31":[4,0,1,2],"0":[0,1],"20":[2,0],"27":[0,4,2],"2":[2,0],"18":[1,3,0],"30":[0,1],"7":[1,2],"29":[2,1],"3":[0,2],"28":[1,0]}} for replica assignment (kafka.controller.KafkaController) 2088 [2015-01-05 10:01:06,001] INFO [Controller 2]: Updated assigned replicas for partition [testingTopic,9] being reassigned to 2,1,0 (kafka.controller.KafkaController) 2089 [2015-01-05 10:01:06,001] DEBUG [Controller 2]: Updating leader epoch for partition [testingTopic,9]. (kafka.controller.KafkaController) 2090 [2015-01-05 10:01:06,007] INFO [Controller 2]: Updated leader epoch for partition [testingTopic,9] to 4 (kafka.controller.KafkaController) 2091 [2015-01-05 10:01:06,046] INFO [Replica state machine on controller 2]: Invoking state change to NewReplica for replicas [Topic=testingTopic,Partition=9,Replica=1] (kafka.controller.ReplicaStateMachine) 2092 [2015-01-05 10:01:06,076] INFO [Controller 2]: Waiting for new replicas 2,1 for partition [testingTopic,9] being reassigned to catch up with the leader (kafka.controller.KafkaController) ... 2370 [2015-01-05 10:01:07,725] INFO [ReassignedPartitionsIsrChangeListener on controller 2]: 1/2 replicas have caught up with the leader for partition [testingTopic,9] being reassigned.Replica(s) 1 still need to catch up (kafka.controller.ReassignedPartitionsIsrChangeListener) ... 2422 [2015-01-05 10:28:19,675] INFO [ControllerEpochListener on 2]: Initialized controller epoch to 2509 and zk version 2508 (kafka.controller.ControllerEpochListener) 2423 [2015-01-05 10:28:19,732] INFO [Controller 2]: Controller starting up (kafka.controller.KafkaController) 2424 [2015-01-05 10:28:19,786] INFO [Controller 2]: Controller startup complete (kafka.controller.KafkaController) ************************************************** server.log on Broker-1: ************************************************** 76200 [2015-01-05 10:01:05,911] INFO Created log for partition [testingTopic,9] in /home/storm/kafka_2.9.2-0.8.1/logs with properties {segment.index.bytes -> 10485760, file.delete.delay.ms -> 60000, segment.bytes -> 536870912, flush.ms -> 9223372036854775807, delete.retention.ms -> 86400000, index.interval.bytes -> 4096, retention.bytes -> -1, cleanup.policy -> delete, segment.ms -> 604800000, max.message.bytes -> 1000012, flush.messages -> 9223372036854775807, min.cleanable.dirty.ratio -> 0.5, retention.ms -> 86400000}. (kafka.log.LogManager) 76201 [2015-01-05 10:01:05,912] WARN Partition [testingTopic,9] on broker 1: No checkpointed highwatermark is found for partition [testingTopic,9] (kafka.cluster.Partition) 76202 [2015-01-05 10:01:05,913] INFO [ReplicaFetcherManager on broker 1] Removed fetcher for partitions [testingTopic,9] (kafka.server.ReplicaFetcherManager) 76203 [2015-01-05 10:01:05,913] INFO Truncating log testingTopic-9 to offset 0. (kafka.log.Log) 76204 [2015-01-05 10:01:05,914] INFO [ReplicaFetcherManager on broker 1] Added fetcher for partitions ArrayBuffer([[testingTopic,9], initOffset 0 to broker id:2,host:10.4.11.92,port:9092] ) (kafka.server.ReplicaFetcherManager) ************************************************** server.log on Broker-0: ************************************************** 108035 [2015-01-05 10:27:02,874] INFO Truncating log testingTopic-9 to offset 25250551. (kafka.log.Log) 108036 [2015-01-05 10:27:02,875] INFO Scheduling log segment 25477161 for log testingTopic-9 for deletion. (kafka.log.Log) 108037 [2015-01-05 10:27:02,875] INFO Scheduling log segment 25970988 for log testingTopic-9 for deletion. (kafka.log.Log) 108038 [2015-01-05 10:27:02,875] INFO Scheduling log segment 26461843 for log testingTopic-9 for deletion. (kafka.log.Log) 108039 [2015-01-05 10:27:02,875] INFO Scheduling log segment 26953183 for log testingTopic-9 for deletion. (kafka.log.Log) 108040 [2015-01-05 10:27:02,875] INFO Scheduling log segment 27446641 for log testingTopic-9 for deletion. (kafka.log.Log) 108041 [2015-01-05 10:27:02,875] INFO Scheduling log segment 27940111 for log testingTopic-9 for deletion. (kafka.log.Log) 108042 [2015-01-05 10:27:02,876] INFO Scheduling log segment 28437156 for log testingTopic-9 for deletion. (kafka.log.Log) 108043 [2015-01-05 10:27:02,876] INFO Scheduling log segment 28936661 for log testingTopic-9 for deletion. (kafka.log.Log) 108044 [2015-01-05 10:27:02,876] INFO Scheduling log segment 29441436 for log testingTopic-9 for deletion. (kafka.log.Log) 108045 [2015-01-05 10:27:02,876] INFO Scheduling log segment 29955494 for log testingTopic-9 for deletion. (kafka.log.Log) 108046 [2015-01-05 10:27:02,876] INFO Scheduling log segment 30480623 for log testingTopic-9 for deletion. (kafka.log.Log) 108047 [2015-01-05 10:27:02,877] INFO Scheduling log segment 31024714 for log testingTopic-9 for deletion. (kafka.log.Log) 108048 [2015-01-05 10:27:02,877] INFO Scheduling log segment 31581247 for log testingTopic-9 for deletion. (kafka.log.Log) 108049 [2015-01-05 10:27:02,877] INFO Scheduling log segment 32160781 for log testingTopic-9 for deletion. (kafka.log.Log) 108050 [2015-01-05 10:27:02,877] INFO Scheduling log segment 32756802 for log testingTopic-9 for deletion. (kafka.log.Log) 108051 [2015-01-05 10:27:02,877] INFO Scheduling log segment 33349050 for log testingTopic-9 for deletion. (kafka.log.Log) 108052 [2015-01-05 10:27:02,878] INFO Scheduling log segment 33919082 for log testingTopic-9 for deletion. (kafka.log.Log) 108053 [2015-01-05 10:27:02,878] INFO Scheduling log segment 34450242 for log testingTopic-9 for deletion. (kafka.log.Log) 108054 [2015-01-05 10:27:03,036] WARN [ReplicaFetcherThread-0-1], Replica 0 for partition [testingTopic,9] reset its fetch offset to current leader 1's latest offset 25250551 (kafka.server.ReplicaFetcherThread) 108055 [2015-01-05 10:27:03,037] ERROR [ReplicaFetcherThread-0-1], Current offset 34836985 for partition [testingTopic,9] out of range; reset offset to 25250551 (kafka.server.ReplicaFetcherThread) **************************************************