This is an automated email from the ASF dual-hosted git repository.
duansg pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hertzbeat.git
The following commit(s) were added to refs/heads/master by this push:
new f7b0010180 fix: Remove redundant metrics data send in
KafkaCommonDataQueue (#3854)
f7b0010180 is described below
commit f7b0010180ab8cc3567b46ef71b90cbcfd93e0d1
Author: starryCoder <[email protected]>
AuthorDate: Mon Nov 24 22:11:49 2025 +0800
fix: Remove redundant metrics data send in KafkaCommonDataQueue (#3854)
Co-authored-by: Calvin <[email protected]>
Co-authored-by: Duansg <[email protected]>
---
.../org/apache/hertzbeat/common/queue/impl/KafkaCommonDataQueue.java | 2 +-
hertzbeat-startup/src/main/resources/application.yml | 1 +
script/application.yml | 1 +
3 files changed, 3 insertions(+), 1 deletion(-)
diff --git
a/hertzbeat-common/src/main/java/org/apache/hertzbeat/common/queue/impl/KafkaCommonDataQueue.java
b/hertzbeat-common/src/main/java/org/apache/hertzbeat/common/queue/impl/KafkaCommonDataQueue.java
index a9286de13e..17b4e3d4d4 100644
---
a/hertzbeat-common/src/main/java/org/apache/hertzbeat/common/queue/impl/KafkaCommonDataQueue.java
+++
b/hertzbeat-common/src/main/java/org/apache/hertzbeat/common/queue/impl/KafkaCommonDataQueue.java
@@ -118,7 +118,7 @@ public class KafkaCommonDataQueue implements
CommonDataQueue, DisposableBean {
Map<String, Object> metricsToStorageConsumerConfig = new
HashMap<>(consumerConfig);
metricsToStorageConsumerConfig.put("group.id",
"metrics-persistent-consumer");
metricsDataToStorageConsumer = new
KafkaConsumer<>(metricsToStorageConsumerConfig, new LongDeserializer(), new
KafkaMetricsDataDeserializer());
-
metricsDataToStorageConsumer.subscribe(Collections.singletonList(kafka.getMetricsDataTopic()));
+
metricsDataToStorageConsumer.subscribe(Collections.singletonList(kafka.getMetricsDataToStorageTopic()));
Map<String, Object> serviceDiscoveryDataConsumerConfig = new
HashMap<>(consumerConfig);
serviceDiscoveryDataConsumerConfig.put("group.id",
"service-discovery-data-consumer");
diff --git a/hertzbeat-startup/src/main/resources/application.yml
b/hertzbeat-startup/src/main/resources/application.yml
index c4f4636014..e141b4606c 100644
--- a/hertzbeat-startup/src/main/resources/application.yml
+++ b/hertzbeat-startup/src/main/resources/application.yml
@@ -150,6 +150,7 @@ common:
kafka:
servers: 127.0.0.1:9092
metrics-data-topic: async-metrics-data
+ metrics-data-to-storage-topic: metrics-data-to-storage-topic
service-discovery-data-topic: service-discovery-data
alerts-data-topic: async-alerts-data
log-entry-data-topic: async-log-entry-data
diff --git a/script/application.yml b/script/application.yml
index c4f4636014..e141b4606c 100644
--- a/script/application.yml
+++ b/script/application.yml
@@ -150,6 +150,7 @@ common:
kafka:
servers: 127.0.0.1:9092
metrics-data-topic: async-metrics-data
+ metrics-data-to-storage-topic: metrics-data-to-storage-topic
service-discovery-data-topic: service-discovery-data
alerts-data-topic: async-alerts-data
log-entry-data-topic: async-log-entry-data
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
