Embedded Kafka Refresh Messages Between Tests...

After upgrade kafka to 2.x, my UT cannot be launched after using latest EmbeddedKafkaRule...

Update spring-kafka-test to 2.2.x but still use old kafka-client 1.1.1 with junit5 and spring boot 2...

Sending using KafkaTemplate<String, String> returns a exception for using String as a key...

Spring kafka error Caused by: java.lang.ClassNotFoundException: org.springframework.kafka.transactio...