From f731c25856ad6f3d7cfac1633bac121bee5abf55 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=90=B4=E6=99=9F=20Wu=20Sheng?= Date: Sun, 16 Aug 2020 07:05:40 +0800 Subject: [PATCH] Miss topic in the KafkaServiceManagementServiceClient (#5326) Co-authored-by: Daming --- .../agent/core/kafka/KafkaServiceManagementServiceClient.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/apm-sniffer/optional-reporter-plugins/kafka-reporter-plugin/src/main/java/org/apache/skywalking/apm/agent/core/kafka/KafkaServiceManagementServiceClient.java b/apm-sniffer/optional-reporter-plugins/kafka-reporter-plugin/src/main/java/org/apache/skywalking/apm/agent/core/kafka/KafkaServiceManagementServiceClient.java index 2f67911921..2b99d50f72 100644 --- a/apm-sniffer/optional-reporter-plugins/kafka-reporter-plugin/src/main/java/org/apache/skywalking/apm/agent/core/kafka/KafkaServiceManagementServiceClient.java +++ b/apm-sniffer/optional-reporter-plugins/kafka-reporter-plugin/src/main/java/org/apache/skywalking/apm/agent/core/kafka/KafkaServiceManagementServiceClient.java @@ -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 -- GitLab