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

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

生产者发送消息到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.BrokerKaTeX parse error: Can't use function '$' in math mode at position 8: anonfun$̲4.apply(Broker.…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 4.apply(Broker.scala:125) at scala.collection.MapLike 4.apply(Broker.scala:125)atscala.collection.MapLikeclass.getOrElse(MapLike.scala:128)
at scala.collection.AbstractMap.getOrElse(Map.scala:59)
at kafka.cluster.Broker.getNode(Broker.scala:124)
at kafka.admin.AdminUtilsKaTeX parse error: Can't use function '$' in math mode at position 8: anonfun$̲19.liftedTree1$…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 19.apply(AdminUtils.scala:582) at kafka.admin.AdminUtils 19.apply(AdminUtils.scala:582)atkafka.admin.AdminUtils$anonfun$19.apply(AdminUtils.scala:569)
at scala.collection.immutable.List.map(List.scala:284)

Caused by: kafka.common.BrokerEndPointNotAvailableException: End point with security protocol PLAINTEXT not found for broker 1001

Caused by: kafka.common.BrokerEndPointNotAvailableException: End point with security protocol PLAINTEXT not found for broker 1002

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

如果出现生产者发送消息到topic缓慢很可能是鉴权问题。
例如，调用TBDS的Kafka组件需要加入SecretId和SecretKey和其他两个属性配置信息如下：