DBZ-8282 Added record key to KafkaChangeConsumer ERROR log.

debezium · Oct 2, 2024 · e4994bf · e4994bf
1 parent 4d50b7a
commit e4994bf
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/debezium-server-kafka/src/main/java/io/debezium/server/kafka/KafkaChangeConsumer.java b/debezium-server-kafka/src/main/java/io/debezium/server/kafka/KafkaChangeConsumer.java
@@ -5,6 +5,7 @@
  */
 package io.debezium.server.kafka;
 
+import java.nio.charset.StandardCharsets;
 import java.time.Duration;
 import java.util.ArrayList;
 import java.util.List;
@@ -103,7 +104,8 @@ public void handleBatch(final List<ChangeEvent<Object, Object>> records,
                 deliveryFutures.add(producer.send(new ProducerRecord<>(topicName, null, null, record.key(), record.value(), headers),
                         (metadata, exception) -> {
                             if (exception != null) {
-                                LOGGER.error("Failed to send record to {}:", topicName, exception);
+                                LOGGER.error("Failed to send record with key '{}' to {}:", new String((byte[]) record.key(), StandardCharsets.UTF_8), topicName,
+                                        exception);
                                 throw new DebeziumException(exception);
                             }
                             else {