Merge branch 'master' into master

apache · Nov 4, 2024 · 244f23a · 244f23a
2 parents dda33ed + 8aec251
commit 244f23a
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/...ka/src/main/java/org/apache/shenyu/plugin/logging/kafka/client/KafkaLogCollectClient.java b/...ka/src/main/java/org/apache/shenyu/plugin/logging/kafka/client/KafkaLogCollectClient.java
@@ -122,7 +122,11 @@ public void consume0(@NonNull final List<ShenyuRequestLog> logs) {
                     .map(apiConfig -> StringUtils.defaultIfBlank(apiConfig.getTopic(), topic)
                     ).orElse(topic);
             try {
-                producer.send(toProducerRecord(logTopic, log));
+                producer.send(toProducerRecord(logTopic, log), (metadata, exception) -> {
+                    if (Objects.nonNull(exception)) {
+                        LOG.error("kafka push logs error", exception);
+                    }
+                });
             } catch (Exception e) {
                 LOG.error("kafka push logs error", e);
             }