From: Kai Moritz Date: Tue, 28 Jan 2025 20:33:54 +0000 (+0100) Subject: WIP X-Git-Url: https://juplo.de/gitweb/?a=commitdiff_plain;h=422dc3680060e25d92cf5bfcaa0b214331ee322e;p=demos%2Fkafka%2Ftraining WIP --- diff --git a/src/test/java/de/juplo/kafka/ApplicationTests.java b/src/test/java/de/juplo/kafka/ApplicationTests.java index f4042aaf..76b9efe8 100644 --- a/src/test/java/de/juplo/kafka/ApplicationTests.java +++ b/src/test/java/de/juplo/kafka/ApplicationTests.java @@ -66,9 +66,9 @@ public class ApplicationTests final long[] currentOffsets = new long[PARTITIONS]; @Autowired - KafkaTemplate kafkaTemplate; + KafkaTemplate kafkaTemplate; - private void send(String key, byte[] value) + private void send(String key, Object value) { kafkaTemplate .send(TOPIC, key, value)