From 8e56e06fcf6e44faea1eb1e53c0c376008f099d8 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sun, 15 Dec 2024 11:58:16 +0100 Subject: [PATCH] refactor:TEST --- .../de/juplo/kafka/ExampleConsumerTest.java | 19 ++++++++++++------- 1 file changed, 12 insertions(+), 7 deletions(-) diff --git a/src/test/java/de/juplo/kafka/ExampleConsumerTest.java b/src/test/java/de/juplo/kafka/ExampleConsumerTest.java index 9bb9e3c2..65254e04 100644 --- a/src/test/java/de/juplo/kafka/ExampleConsumerTest.java +++ b/src/test/java/de/juplo/kafka/ExampleConsumerTest.java @@ -173,23 +173,28 @@ public class ExampleConsumerTest private void sendValidMessage(int partition) { - kafkaTemplate.send(TOPIC, partition, "EGAL", serializer.serialize(TOPIC, (long)partition)); + send(partition, partition); } private void sendNonDeserializableMessage(int partition) { - kafkaTemplate.send(TOPIC, partition, "EGAL", "BOOM!".getBytes()); + send(partition, "BOOM!".getBytes()); } private void sendMessageThatTriggersRuntimeExceptionInDomain(int partition) { - kafkaTemplate.send( - TOPIC, - partition, - "EGAL", - serializer.serialize(TOPIC, (long)VALUE_THAT_TRIGGERS_RUNTIMEEXCEPTION)); + send(partition, VALUE_THAT_TRIGGERS_RUNTIMEEXCEPTION); } + private void send(int partition, long message) + { + send(partition, serializer.serialize(TOPIC, message)); + } + + private void send(int partition, byte[] bytes) + { + kafkaTemplate.send(TOPIC, partition, "EGAL", bytes); + } public final static int VALUE_THAT_TRIGGERS_RUNTIMEEXCEPTION = -1; -- 2.20.1