我们最近在其中一个环境中遇到以下异常：
java.lang.NullPointerException
at org.apache.kafka.clients.producer.internals.DefaultPartitioner.partition(DefaultPartitioner.java:70)
at org.apache.kafka.clients.producer.KafkaProducer.partition(KafkaProducer.java:721)
at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:459)
at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:430)这种例外背后可能的根本原因是什么？
查看源代码，以下方法为分区返回空值： org.apache.kafka.common.Cluster#partitionsForTopic
1条答案
按热度按时间b91juud31#
您可能遇到此缺陷：https://issues.apache.org/jira/browse/kafka-3562
即使根本原因是不同的，分区分配和元数据获取之间的一些竞争条件，修复可能会有所帮助，所以我建议更新。现在0.10.0.0已经很老了，以后的版本更稳定。