Kafka Cluster 2019(3)Spring Boot Kafka

Kafka Cluster 2019(3)Spring Boot Kafka

Support more complex object other than String
https://codenotfound.com/spring-kafka-apache-avro-serializer-deserializer-example.html
https://codenotfound.com/spring-kafka-json-serializer-deserializer-example.html


More Option to support in the YAML configuration
https://github.com/spring-projects/spring-boot/blob/v2.1.6.RELEASE/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/kafka/KafkaProperties.java


It supports the Object as well, I just use string for my performance check here
https://docs.spring.io/spring-boot/docs/current/reference/html/boot-features-messaging.html#boot-features-kafka

Here is the pom.xml change
<dependency>
<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka-test</artifactId>
<scope>test</scope>
</dependency>

I just like to use interface, so I define an interface there
package com.sillycat.mvclatency.service;
public interface KafkaService {
public void send(String payload);
}

The implementation class is as follow:
package com.sillycat.mvclatency.service;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Service;

import lombok.extern.slf4j.Slf4j;

@Slf4j
@Service
public class KafkaServiceImpl implements KafkaService {

    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

    public void send(String payload) {
        log.info("sending payload='{}'", payload);
        kafkaTemplate.send("helloworld.mvc", payload);
    }

    @KafkaListener(topics = "helloworld.mvc")
    public void receive(String payload) {
        log.info("received payload='{}'", payload);
    }

}

It will use the kafkaTemplate to send out message, and @KafkaListener to  consume the messages.
Here is the related configuration
spring:
kafka:
  consumer:
   group-id: mvccluster
  bootstrap-servers: ubuntu-master:9092, ubuntu-dev2:9092, ubuntu-dev4:9092

That is it. We can have more configurations, but I just want to compare it with reactive, so I just directly use the simple String one.

References:
https://docs.spring.io/spring-boot/docs/current/reference/html/boot-features-messaging.html#boot-features-kafka
https://codenotfound.com/spring-kafka-consumer-producer-example.html
https://www.e4developer.com/2018/05/21/getting-started-with-kafka-in-spring-boot/
https://codar.club/blogs/reactor-kafka-via-spring-boot-webflux.html
https://github.com/reactor/reactor-kafka

Sample Projects
https://github.com/bjedrzejewski/kafkaintro
https://github.com/TechPrimers/spring-boot-kafka-producer-example
https://github.com/CloudKarafka/springboot-kafka-example

https://www.jianshu.com/p/d811f7421e71