From e57612ca70ec0b8f995e5f73ba0991dd17b33319 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sun, 20 Aug 2023 11:25:25 +0200 Subject: [PATCH] WIP --- .../de/juplo/kafka/chat/backend/KafkaConfigurationIT.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/test/java/de/juplo/kafka/chat/backend/KafkaConfigurationIT.java b/src/test/java/de/juplo/kafka/chat/backend/KafkaConfigurationIT.java index 694b67f4..5f6945ba 100644 --- a/src/test/java/de/juplo/kafka/chat/backend/KafkaConfigurationIT.java +++ b/src/test/java/de/juplo/kafka/chat/backend/KafkaConfigurationIT.java @@ -46,7 +46,7 @@ class KafkaConfigurationIT extends AbstractConfigurationWithShardingIT KafkaServicesApplicationRunner kafkaServicesApplicationRunner; @BeforeAll - public static void sendAndLoadStoredData(, + public static void sendAndLoadStoredData( @Autowired KafkaTemplate messageTemplate, @Autowired Consumer chatRoomChannelConsumer, @Autowired ThreadPoolTaskExecutor taskExecutor, @@ -79,7 +79,7 @@ class KafkaConfigurationIT extends AbstractConfigurationWithShardingIT "Sent {}={} to {}", key, value, - new TopicPartition(result.getRecordMetadata().topic(), result.getRecordMetadata().partition()))); + new TopicPartition(result.getRecordMetadata().topic(), result.getRecordMetadata().partition())); } @AfterAll -- 2.20.1