【Kafka】Kafka BrokerEndPointNotAvailableException: End point with security protocol PLAINTEXT not

原因是你需要登录到Linux服务器去获取映射配置信息，并配置到Windows操作系统上即可。用Kafka的时候是需要配置映射信息的，172.16.122.38是Linux服务器的地址。下面的ZK和Kafka的集群IP地址。

Dragon_JavaEE

1782人浏览 · 2022-01-01 15:25:23

Dragon_JavaEE · 2022-01-01 15:25:23 发布

生产者发送消息到topic
报错信息如下：
org.apache.kafka.common.errors.LeaderNotAvailableException: Leader not available for partition [myTopic0087,0]
Caused by: kafka.common.BrokerEndPointNotAvailableException: End point with security protocol PLAINTEXT not found for broker 1003
at kafka.cluster.Broker $KaTeX parse error: Can't use function '$' in math mode at position 8: anonfun$̲4.apply(Broker.\dots$ anonfun $4 . a p p l y (B r o k e r . s c a l a : 125) a t s c a l a . c o l l e c t i o n . M a p L i k e$ class.getOrElse(MapLike.scala:128)
at scala.collection.AbstractMap.getOrElse(Map.scala:59)
at kafka.cluster.Broker.getNode(Broker.scala:124)
at kafka.admin.AdminUtils $KaTeX parse error: Can't use function '$' in math mode at position 8: anonfun$̲19.liftedTree1$\dots$ anonfun $19 . a p p l y (A d m i n U t i l s . s c a l a : 582) a t k a f k a . a d m i n . A d m i n U t i l s$ $anonfun$19.apply(AdminUtils.scala:569)
at scala.collection.immutable.List.map(List.scala:284)