X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplicationTests.java;h=6c25bcd7808409744fc28b7e742c14d37c23efac;hb=d2f482e5eb951e725f4193f97d979330e91c930e;hp=fbc668ff2aa8491bedb4cbf7475747ef99291c37;hpb=a14a1d5222b18506311cb8fe7c59dfe0f5458cf3;p=demos%2Fkafka%2Ftraining

diff --git a/src/test/java/de/juplo/kafka/ApplicationTests.java b/src/test/java/de/juplo/kafka/ApplicationTests.java
index fbc668f..6c25bcd 100644
--- a/src/test/java/de/juplo/kafka/ApplicationTests.java
+++ b/src/test/java/de/juplo/kafka/ApplicationTests.java
@@ -203,6 +203,7 @@ class ApplicationTests
 								Integer.toString(key%2),
 								value);
 
+				record.headers().add("__TypeId__", "message".getBytes());
 				kafkaProducer.send(record, (metadata, e) ->
 				{
 					if (metadata != null)