Kafka Consumer报错NOT_LEADER_FOR_P

解决了一个Kafka consumer报错的问题

org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=test] Attempt to fetch offsets for partition xxxx-0 failed due to NOT_LEADER_FOR_PARTITION, retrying.

使用的依赖关系是

pom.xml的依赖关系

通过topic描述信息，发现这个topic对应的broker.id=3

./kaftopics.sh --describe --zookeeper zk1.iot.local:2181,zk2.iot.local:2181,zk3.iot.local:2181 --topic iot_edge_sgcc_sync

Topic: iot_edge_sgcc_sync Partition: 0 Leader: 3 Replicas: 3 Isr: 3

由于某些原因，这个broker所在的服务器没有对外的ip，所以从客户端无法连接。原来如此

接下来就好搞了，修改parition分区到另外一个有外网IP的broker，操作步骤可以参考https://www.cnblogs.com/blazeZzz/p/10242679.html

修改完后再次查看topic信息，已经更新。再次启动kafka consumer，可以正确读取了

Topic: iot_edge_sgcc_sync Partition: 0 Leader: 1 Replicas: 1 Isr: 1