X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FMultiMessageConsumer.java;h=f0b12ef0349c808b012b666a8062b69ad4028a93;hb=HEAD;hp=e6179e16965cbede09a8c473448e71b362502cb3;hpb=4a47513393bbe1aaaf8c9674ad978de5da2a9d7d;p=demos%2Fkafka%2Fkafkahandler

diff --git a/src/main/java/de/juplo/kafka/MultiMessageConsumer.java b/src/main/java/de/juplo/kafka/MultiMessageConsumer.java
index e6179e1..f0b12ef 100644
--- a/src/main/java/de/juplo/kafka/MultiMessageConsumer.java
+++ b/src/main/java/de/juplo/kafka/MultiMessageConsumer.java
@@ -51,4 +51,17 @@ public class MultiMessageConsumer
         metadata.offset());
     bars.add(bar);
   }
+
+  @KafkaHandler(isDefault = true)
+  void handleUnknown(
+      @Payload Object unknown,
+      @Header(KafkaHeaders.RECORD_METADATA) ConsumerRecordMetadata metadata)
+  {
+    log.info(
+        "Received an unknown message: {}",
+        unknown,
+        metadata.topic(),
+        metadata.partition(),
+        metadata.offset());
+  }
 }