SpringKafka Test KafkaEmbedded Sınıfı

Giriş

Şu satırı dahil ederiz

import org.springframework.kafka.test.rule.KafkaEmbedded;

constructor
Şöyle yaparız.

 @ClassRule
public static KafkaEmbedded embeddedKafka = new KafkaEmbedded(1, true,
  Topology.DEMO_TOPIC);