KafkaServicesApplicationRunner kafkaServicesApplicationRunner;
@BeforeAll
- public static void sendAndLoadStoredData(,
+ public static void sendAndLoadStoredData(
@Autowired KafkaTemplate<String, String> messageTemplate,
@Autowired Consumer chatRoomChannelConsumer,
@Autowired ThreadPoolTaskExecutor taskExecutor,
"Sent {}={} to {}",
key,
value,
- new TopicPartition(result.getRecordMetadata().topic(), result.getRecordMetadata().partition())));
+ new TopicPartition(result.getRecordMetadata().topic(), result.getRecordMetadata().partition()));
}
@AfterAll