From: Kai Moritz Date: Sun, 20 Aug 2023 09:25:25 +0000 (+0200) Subject: WIP X-Git-Tag: rebase--2023-08-20~2 X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=e57612ca70ec0b8f995e5f73ba0991dd17b33319;p=demos%2Fkafka%2Fchat WIP --- 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