Update

Author: Kevded

src/main/java/com/example/integrationtestspringkafka/service/ConsumerService.java

@@ -17,6 +17,12 @@ public class ConsumerService {
  this.exampleRepository = exampleRepository;
  }
 
+ /**
+ * Consume ExampleDTO on topic : TOPIC_EXAMPLE
+ * Then save it in database.
+ *
+ * @param exampleDTO
+ */
  @KafkaListener(topics = "TOPIC_EXAMPLE")
  public void consumeExampleDTO(ExampleDTO exampleDTO) {
  log.info("Received from topic=TOPIC_EXAMPLE ExampleDTO={}", exampleDTO);

src/main/java/com/example/integrationtestspringkafka/service/ProducerService.java

@@ -10,14 +10,19 @@
 public class ProducerService {
  Logger log = LoggerFactory.getLogger(ProducerService.class);
 
- private String topic = "TOPIC_EXAMPLE";
+ private String topic = "TOPIC_EXAMPLE_EXTERNE";
 
  private KafkaTemplate<String, ExampleDTO> kafkaTemplate;
 
  ProducerService(KafkaTemplate kafkaTemplate) {
  this.kafkaTemplate = kafkaTemplate;
  }
 
+ /**
+ * Send ExampleDTO to an external topic : TOPIC_EXAMPLE_EXTERNE.
+ *
+ * @param exampleDTO
+ */
  public void send(ExampleDTO exampleDTO) {
  log.info("send to topic={} ExampleDTO={}", topic, exampleDTO);
  kafkaTemplate.send(topic, exampleDTO);