springboot整合kafka

1.导入依赖
不管是生产者还是消费者，你都需要导入如下依赖

	org.springframework.kafka
	spring-kafka

2. 生产者整合

2.1 配置信息
demo里只使用了最基本的参数，可以根据需要添加其它参数。前面一篇kafka相关文章里有介绍其它参数

#borker地址
spring.kafka.bootstrap-servers=192.168.3.107:9092
#key序列化方式
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
#value序列化方式
spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer

2.2 代码使用
注入KafkaTemplate，然后调用发送消息相关的send方法就可以。send方法可以指定很多参数，例如：topic,key，partition等等。

3. 消费者整合

3.1 配置

#borker地址
spring.kafka.bootstrap-servers=192.168.3.107:9092
#key value反序列化方式
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer

3.2 代码
创建一个配置类，然后使用@KafkaListener注解监听指定的topic的消息就好，该注解还可以指定其它相关参数，例如：partition

@Configuration
public class KafkaConsumer {

    @KafkaListener(topics = "test1",groupId = "group2")
    public void accpetMsg(String msg){
        System.out.println("消费消息："+msg);
    }
}