生产者发送消息到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和其他两个属性配置信息如下：
