darcydai commented on a change in pull request #6781:
URL: https://github.com/apache/skywalking/pull/6781#discussion_r615870774
##########
File path:
apm-sniffer/optional-reporter-plugins/kafka-reporter-plugin/src/main/java/org/apache/skywalking/apm/agent/core/kafka/KafkaJVMMetricsSender.java
##########
@@ -96,4 +94,11 @@ public void offer(final JVMMetric metric) {
queue.offer(metric);
}
}
+
+ @Override
+ public void onStatusChanged(KafkaConnectionStatus status) {
+ if (status == KafkaConnectionStatus.CONNECTED) {
+ producer =
ServiceManager.INSTANCE.findService(KafkaProducerManager.class).getProducer();
+ }
+ }
Review comment:
retry logical means that it will retry in bootstrap if KafkaProducer
creates failure. see this class named KafkaProducerManager, it has a schedule
thread pool to retry until KafkaProducer created
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
