未验证 提交 f731c258 编写于 作者: wu-sheng's avatar wu-sheng 提交者: GitHub

Miss topic in the KafkaServiceManagementServiceClient (#5326)

Co-authored-by: NDaming <zteny@foxmail.com>
上级 68eba154
......@@ -106,7 +106,7 @@ public class KafkaServiceManagementServiceClient implements BootService, Runnabl
if (logger.isDebugEnable()) {
logger.debug("Heartbeat reporting, instance: {}", ping.getServiceInstance());
}
producer.send(new ProducerRecord<>(ping.getServiceInstance(), Bytes.wrap(ping.toByteArray())));
producer.send(new ProducerRecord<>(topic, ping.getServiceInstance(), Bytes.wrap(ping.toByteArray())));
}
@Override
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册