可用性测试中通过kafka发送消息失败

Question

[2021-12-12 15:28:22:297] Thread-47 INFO c.a.m.listener.AggregationListener 78 - trigger event : EXT_UPDATE_ROWS
[2021-12-12 15:28:22:301] Thread-47 INFO com.ad.sender.kafka.KafkaSender 32 - binlog kafka service send MySqlRowData...
[2021-12-12 15:28:22:918] kafka-producer-network-thread | producer-1 WARN o.apache.kafka.clients.NetworkClient 246 - [Producer clientId=producer-1] Error while fetching metadata with correlation id 1 : {${adconf.kafka.topic=INVALID_TOPIC_EXCEPTION}
[2021-12-12 15:29:22:502] Thread-47 ERROR o.s.k.s.LoggingProducerListener 76 - Exception thrown when sending a message with key='null' and payload='{"fieldValueMap":[Exception thrown when sending a message with key='null' and payload='{"fieldValueMap":[{}],"level":"2","opType":"UPDATE","tableName":"ad_plan"}' to topic ${adconf.kafka.topic:],"level":"2","opType":"UPDATE","tableName":"ad_plan"}' to topic ${adconf.kafka.topic:
org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.

报错信息

Answer 1

张勤一 2021-12-12 22:40:11

同学你好：

    程序没有连接上 kafka。

• 提问者 bkpp2018 #1

  是pom.xml的问题，直接从源代码中复制下来并且修改了kafka.bootstrap-servers的ip地址，生产者端也就是ad-binlog-kafka没有连接到服务器的kafka，重新自己敲了一遍kafka.bootstrap-servers就可以了

Answer 2

张勤一 2021-12-12 22:40:11

同学你好：

    程序没有连接上 kafka。

Answer 3

张勤一 2021-12-12 22:40:10

同学你好：

    程序没有连接上 kafka。