WIP
authorKai Moritz <kai@juplo.de>
Sun, 20 Aug 2023 09:25:25 +0000 (11:25 +0200)
committerKai Moritz <kai@juplo.de>
Sun, 20 Aug 2023 09:25:25 +0000 (11:25 +0200)
src/test/java/de/juplo/kafka/chat/backend/KafkaConfigurationIT.java

index 694b67f..5f6945b 100644 (file)
@@ -46,7 +46,7 @@ class KafkaConfigurationIT extends AbstractConfigurationWithShardingIT
   KafkaServicesApplicationRunner kafkaServicesApplicationRunner;
 
   @BeforeAll
-  public static void sendAndLoadStoredData(,
+  public static void sendAndLoadStoredData(
       @Autowired KafkaTemplate<String, String> 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