Broker.id=2 restart??run bottom sh??
ghy@ghy-VirtualBox:~/T/k/bin$ ./kafka-topics.sh --describe --bootstrap-server
localhost:9083 --topic my-replicated-topic
Topic: my-replicated-topic PartitionCount:
3 ReplicationFactor:
3 Configs: segment.bytes=1073741824
Topic:
my-replicated-topic Partition:
0 Leader: 3 Replicas: 3,2,1 Isr: 3,1,2
Topic:
my-replicated-topic Partition:
1 Leader: 1 Replicas: 1,3,2 Isr: 1,3,2
Topic:
my-replicated-topic Partition:
2 Leader: 1 Replicas: 2,1,3 Isr: 1,3,2
ghy@ghy-VirtualBox:~/T/k/bin$
Broker.id=2 not found!!
reassign partitions bottom 5 step??
??1??create AddNewNode.json file:
{
"topics": [{"topic": "my-replicated-topic"}],
"version":1
}
??2????
ghy@ghy-VirtualBox:~/T/k/bin$ ./kafka-reassign-partitions.sh --zookeeper
localhost:2181/cluster_1 --topics-to-move-json-file AddNewNode.json
--broker-list "1,2,3" --generate
Current partition replica assignment
{"version":1,"partitions":[{"topic":"my-replicated-topic","partition":0,"replicas":[3,2,1],"log_dirs":["any","any","any"]},{"topic":"my-replicated-topic","partition":1,"replicas":[1,3,2],"log_dirs":["any","any","any"]},{"topic":"my-replicated-topic","partition":2,"replicas":[2,1,3],"log_dirs":["any","any","any"]}]}
Proposed partition reassignment configuration
{"version":1,"partitions":[{"topic":"my-replicated-topic","partition":0,"replicas":[2,1,3],"log_dirs":["any","any","any"]},{"topic":"my-replicated-topic","partition":1,"replicas":[3,2,1],"log_dirs":["any","any","any"]},{"topic":"my-replicated-topic","partition":2,"replicas":[1,3,2],"log_dirs":["any","any","any"]}]}
ghy@ghy-VirtualBox:~/T/k/bin$
{"version":1,"partitions":[{"topic":"my-replicated-topic","partition":0,"replicas":[2,1,3],"log_dirs":["any","any","any"]},{"topic":"my-replicated-topic","partition":1,"replicas":[3,2,1],"log_dirs":["any","any","any"]},{"topic":"my-replicated-topic","partition":2,"replicas":[1,3,2],"log_dirs":["any","any","any"]}]}
json text
save AddNewNode_Reassign-Partitions.json file??
??3??execute??
ghy@ghy-VirtualBox:~/T/k/bin$ ./kafka-reassign-partitions.sh --zookeeper
localhost:2181/cluster_1 --reassignment-json-file
AddNewNode_Reassign-Partitions.json --execute
Current partition replica assignment
{"version":1,"partitions":[{"topic":"my-replicated-topic","partition":0,"replicas":[3,2,1],"log_dirs":["any","any","any"]},{"topic":"my-replicated-topic","partition":1,"replicas":[1,3,2],"log_dirs":["any","any","any"]},{"topic":"my-replicated-topic","partition":2,"replicas":[2,1,3],"log_dirs":["any","any","any"]}]}
Save this to use as the --reassignment-json-file option during rollback
Successfully started reassignment of partitions.
ghy@ghy-VirtualBox:~/T/k/bin$
??4??veryify??
ghy@ghy-VirtualBox:~/T/k/bin$ ./kafka-reassign-partitions.sh --zookeeper
localhost:2181/cluster_1 --reassignment-json-file
AddNewNode_Reassign-Partitions.json --verify
Status of partition reassignment:
Reassignment of partition my-replicated-topic-0 completed successfully
Reassignment of partition my-replicated-topic-1 completed successfully
Reassignment of partition my-replicated-topic-2 completed successfully
ghy@ghy-VirtualBox:~/T/k/bin$
??5??describe??
ghy@ghy-VirtualBox:~/T/k/bin$ ./kafka-topics.sh --describe --bootstrap-server
localhost:9083 --topic my-replicated-topic
Topic: my-replicated-topic PartitionCount:
3 ReplicationFactor:
3 Configs: segment.bytes=1073741824
Topic:
my-replicated-topic Partition:
0 Leader: 3 Replicas: 2,1,3 Isr: 3,1,2
Topic:
my-replicated-topic Partition:
1 Leader: 1 Replicas: 3,2,1 Isr: 1,3,2
Topic:
my-replicated-topic Partition:
2 Leader: 1 Replicas: 1,3,2 Isr: 1,3,2
ghy@ghy-VirtualBox:~/T/k/bin$
why Broker.id=2 not add cluster_1??
Leader only 3 and 1,where 2???
