X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fcounter%2FCounterApplicationIT.java;h=78d103c282fbe7c4857220d6ca581cdc89264189;hb=refs%2Ftags%2Fcounter-1.2.13;hp=5a3507ac0611cef4a87e34288b4a2cca7b9af675;hpb=35943a021ac4b25fad29861ecc083b6974ea2732;p=demos%2Fkafka%2Fwordcount

diff --git a/src/test/java/de/juplo/kafka/wordcount/counter/CounterApplicationIT.java b/src/test/java/de/juplo/kafka/wordcount/counter/CounterApplicationIT.java
index 5a3507a..78d103c 100644
--- a/src/test/java/de/juplo/kafka/wordcount/counter/CounterApplicationIT.java
+++ b/src/test/java/de/juplo/kafka/wordcount/counter/CounterApplicationIT.java
@@ -30,7 +30,10 @@ import java.util.Properties;
 
 import static de.juplo.kafka.wordcount.counter.CounterApplicationIT.*;
 import static de.juplo.kafka.wordcount.counter.TestData.convertToMap;
-import static org.awaitility.Awaitility.*;
+import static de.juplo.kafka.wordcount.counter.TestData.parseHeader;
+import static org.awaitility.Awaitility.await;
+import static org.springframework.kafka.support.mapping.AbstractJavaTypeMapper.*;
+import static org.springframework.kafka.support.mapping.AbstractJavaTypeMapper.DEFAULT_CLASSID_FIELD_NAME;
 
 
 @SpringBootTest(
@@ -81,7 +84,12 @@ public class CounterApplicationIT
 		@KafkaListener(groupId = "TEST", topics = TOPIC_OUT)
 		public synchronized void receive(ConsumerRecord<Word, WordCounter> record)
 		{
-			log.debug("Received message: {}", record);
+			log.debug(
+					"Received message: {} -> {}, key: {}, value: {}",
+					record.key(),
+					record.value(),
+					parseHeader(record.headers(), KEY_DEFAULT_CLASSID_FIELD_NAME),
+					parseHeader(record.headers(), DEFAULT_CLASSID_FIELD_NAME));
 			received.add(KeyValue.pair(record.key(),record.value()));
 		}