[root@prd-kafka-01 opt]# /usr/hdp/2.6.4.0-91/kafka/bin/kafka-reassign-partitions.sh --zookeeper 172.19.38.217:2181 --reassignment-json-file expand-cluster-ods-be-reassignment.json --verify
Status of partition reassignment:
Reassignment of partition [ods_be_monitor_item_detail,8] is still in progress
Reassignment of partition [ods_be_monitor_item_detail,9] completed successfully
Reassignment of partition [ods_be_monitor_item_detail,6] is still in progress
Reassignment of partition [ods_be_monitor_item_detail,14] is still in progress
Reassignment of partition [ods_be_monitor_item_detail,5] is still in progress
Reassignment of partition [ods_be_monitor_item_detail,11] is still in progress
Reassignment of partition [ods_be_monitor_item_detail,13] is still in progress
Reassignment of partition [ods_be_monitor_item_detail,3] is still in progress
Reassignment of partition [ods_be_monitor_item_detail,2] is still in progress
Reassignment of partition [ods_be_monitor_item_detail,4] is still in progress
Reassignment of partition [ods_be_monitor_item_detail,1] is still in progress
Reassignment of partition [ods_be_monitor_item_detail,10] is still in progress
Reassignment of partition [ods_be_monitor_item_detail,12] is still in progress
Reassignment of partition [ods_be_monitor_item_detail,0] completed successfully
Reassignment of partition [ods_be_monitor_item_detail,7] is still in progress
[2020-08-1417:39:01,727] INFO [KafkaApi-1009] Closing connection due toerror during produce request with correlation id572from client id producer-1with ack=0
Topic and partition to exceptions: pshop_sell_status_topic-12 -> org.apache.kafka.common.errors.NotLeaderForPartitionException (kafka.server.KafkaApis)
[2020-08-1417:39:01,877] INFO [KafkaApi-1009] Closing connection due toerror during produce request with correlation id578from client id producer-1with ack=0
Topic and partition to exceptions: pshop_sell_status_topic-2 -> org.apache.kafka.common.errors.NotLeaderForPartitionException (kafka.server.KafkaApis)
[2020-08-1417:39:01,928] INFO [KafkaApi-1009] Closing connection due toerror during produce request with correlation id583from client id producer-1with ack=0
Topic and partition to exceptions: pshop_sell_status_topic-7 -> org.apache.kafka.common.errors.NotLeaderForPartitionException (kafka.server.KafkaApis)
[2020-08-1417:39:02,079] INFO [KafkaApi-1009] Closing connection due toerror during produce request with correlation id589from client id producer-1with ack=0
Topic and partition to exceptions: pshop_sell_status_topic-12 -> org.apache.kafka.common.errors.NotLeaderForPartitionException (kafka.server.KafkaApis)
[2020-08-1417:39:02,129] INFO [KafkaApi-1009] Closing connection due toerror during produce request with correlation id594from client id producer-1with ack=0
Topic and partition to exceptions: pshop_sell_status_topic-2 -> org.apache.kafka.common.errors.NotLeaderForPartitionException (kafka.server.KafkaApis)
[2020-08-1417:40:06,193] INFO [KafkaApi-1009] Closing connection due toerror during produce request with correlation id601from client id producer-1with ack=0
Topic and partition to exceptions: pshop_sell_status_topic-7 -> org.apache.kafka.common.errors.NotLeaderForPartitionException (kafka.server.KafkaApis)
[2020-08-1417:40:06,295] INFO [KafkaApi-1009] Closing connection due toerror during produce request with correlation id608from client id producer-1with ack=0
Topic and partition to exceptions: pshop_sell_status_topic-12 -> org.apache.kafka.common.errors.NotLeaderForPartitionException (kafka.server.KafkaApis)
[2020-08-1418:21:58,656] ERROR [KafkaApi-1009] Error when handling request {controller_id=1005,controller_epoch=22,partition_states=[{topic=monitor_shop_selltime_status_v3,partition=2,controller_epoch=22,leader=1005,leader_epoch=2,isr=[1005,1006,1008],zk_version=13,replicas=[1005,1006,1008,1010,1009]}],live_leaders=[{id=1005,host=kafka1.sh-internal.com,port=6667}]} (kafka.server.KafkaApis)
java.io.IOException: Malformed line inoffset checkpoint file: pshop sell status topic 70'
at kafka.server.OffsetCheckpoint.malformedLineException$1(OffsetCheckpoint.scala:81)
at kafka.server.OffsetCheckpoint.liftedTree2$1(OffsetCheckpoint.scala:104)