彩神大发安卓下载_神彩大发安卓下载官方

class kafka.common.NotLeaderForPartitionException(kafka.server.ReplicaFetcherThread)异常处理

时间:2020-01-01 23:28:42 出处:彩神大发安卓下载_神彩大发安卓下载官方

   {"topic":"2_0_2_20170618","partition":21},

kafka-preferred-replica-election.sh --zookeeper node001:2181,node002:2181,node003:2181/kafka --path-to-json-file  ./partition_elec.json

   {"topic":"2_0_1_hdfs_60 89_kafka_2_20170618","partition":44},

kafka-preferred-replica-election.sh --zookeeper node001:2181,node002:2181,node003:2181/kafka

利用

   {"topic":"sdk_HDFS_168_20170618","partition":44}

[2017-06-15 19:33:14,718] ERROR [ReplicaFetcherThread-0-0], Error for partition [3_7_0_20170615,6] to broker 0:class kafka.common.NotLeaderForPartitionException(kafka.server.ReplicaFetcherThread)

不可能 有越来越来越多topic报错,建议直接对所有topic进行:

只均衡个别topic的个别partition

  [ 

   {"topic":"3_0_20170618","partition":19},

执行

   {"topic":"3_7_0_hdfs_60 89_kafka_20170618","partition":13},

tail -n60 kafkaServer.out | grepNotLeaderForPartitionException | awk -F"partition " '{print $2}' |awk -F"]" '{print $1}' | awk -F"[" '{print $2}'| sort |uniq | sort

  ] 

制作json文件(node005 /opt/isu/kafka/bin下有)

 "partitions":

}

[2017-06-15 19:33:14,716] ERROR [ReplicaFetcherThread-0-0], Error for partition [3_7_0_20170615,6] to broker 0:class kafka.common.NotLeaderForPartitionException (kafka.server.ReplicaFetcherThread)

热门

热门标签