kafka2.5.0生产者与消费者配置详解

1)引入maven依赖

我这里使用的是springboot 2.1.3.RELEASE 版本:

<dependency>
    <groupId>org.springframework.kafka</groupId>
    <artifactId>spring-kafka</artifactId>
</dependency>

会引入一对的kafka包:

kafka2.5.0生产者与消费者配置详解

 

 2)生产者配置:

所有配置参考kafka-clients-2.5.0.jar包里的org.apache.kafka.clients.producer.ProducerConfig类:

application.properties里可以这样配置:

 

如果需要手动封装 @bean对象:

 

 

3)消费者配置:

 

 

 

end.

上一篇:JedisConnectionException: java.net.SocketTimeoutException:


下一篇:Go Pentester - HTTP CLIENTS(4)