kafka storm任务频繁出现以下错误 This server is not the leader for that topic-partition.

zk和kafka都是三台

org.apache.kafka.common.errors.NotLeaderForPartitionException This server is not the leader for that topic-partition.

server.properties 配置

--listing properties--
port=9092
socket. request. max. bytes=104857600
num. io. threads=60
Log. dirs=/data01/kafka-logs
socket. send. buffer. bytes=102400
zookeeper. connect=simuwel101:2181, simuwel102:2181, simuwell03:2181
log. retention. check. interval. ms=300000
broker. id=1
Log. retention. hours=72
num. network. threads=300
queued. max. requests=2000
socket. receive. buffer. bytes=102400
num. recovery. threads. per. data. dir=1
zookeeper. connection. timeout. ms=6000
num. partitions=3
delete. topic. enable=true

zookeeper 配置

tickTime=2000
initlimit =10
syncLimit=5
dataDir=/data01/zookeeper

clientPort=2181
server.1=simuwel101:2888:3888
server.2=simuwel102:2888:3888
server.3=simuweL103:2888:3888
autopurge. snapRetainCount=3
autopurge. purgeInterval=1
maxClientCnxns=1000