This is an automated email from the ASF dual-hosted git repository.
shenghang 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 b8c5ae4d40 [bugfix] kafka client detect error (#3088)
b8c5ae4d40 is described below
commit b8c5ae4d4086f68e48562f9101baa7a4c559bc1d
Author: Nick Guo <[email protected]>
AuthorDate: Fri Feb 21 22:05:12 2025 +0800
[bugfix] kafka client detect error (#3088)
Co-authored-by: Jast <[email protected]>
Co-authored-by: tomsun28 <[email protected]>
---
.../org/apache/hertzbeat/collector/collect/kafka/KafkaCollectImpl.java | 2 ++
1 file changed, 2 insertions(+)
diff --git
a/hertzbeat-collector/hertzbeat-collector-kafka/src/main/java/org/apache/hertzbeat/collector/collect/kafka/KafkaCollectImpl.java
b/hertzbeat-collector/hertzbeat-collector-kafka/src/main/java/org/apache/hertzbeat/collector/collect/kafka/KafkaCollectImpl.java
index ec501172b3..92248a133a 100644
---
a/hertzbeat-collector/hertzbeat-collector-kafka/src/main/java/org/apache/hertzbeat/collector/collect/kafka/KafkaCollectImpl.java
+++
b/hertzbeat-collector/hertzbeat-collector-kafka/src/main/java/org/apache/hertzbeat/collector/collect/kafka/KafkaCollectImpl.java
@@ -267,6 +267,8 @@ public class KafkaCollectImpl extends AbstractCollect {
break;
}
} catch (InterruptedException | ExecutionException e) {
+ builder.setCode(CollectRep.Code.FAIL);
+ builder.setMsg("Kafka collect error: " + e.getMessage());
log.error("Kafka collect error", e);
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
