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

来源：17-9 【正确性检验】广告检索微服务重构后的可用性测试

bkpp2018

2021-12-12

[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.

报错信息

写回答

3回答