Kafka | SpringBoot集成Kafka

SpringBoot集成Kafka

• 一、前言
• 二、项目
• • 1. pom
  • 2. application.properties
  • 4. 消息生产者-测试
  • 5. 消息消费者
  • 三、启动测试
  • 四、���总结的不对的地方/或者问题 请指正, 我在努力中

    一、前言

    该文章中主要对SpringBoot 集成Kafka 主要是 application.properties 与 pom坐标就算集成完成，剩下的就是一些 消费者 / 发布者的操作了详细的请看项目代码。简简单单 快速集成

    二、项目

    1. pom

             org.springframework.kafka         spring-kafka

    2. application.properties

    spring.kafka.bootstrap-servers=192.168.0.113:9092# 生产者配置spring.kafka.producer.retries=2spring.kafka.producer.batch-size=16384spring.kafka.producer.buffer-memory=33554432spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializerspring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializerspring.kafka.producer.acks=-1# 消费者配置spring.kafka.consumer.enable-auto-commit=truespring.kafka.consumer.auto-commit-interval.ms=1000spring.kafka.consumer.auto-offset-reset=latestspring.kafka.consumer.max-poll-records=500spring.kafka.consumer.fetch-max-wait.ms=500spring.kafka.consumer.fetch-min-size=1spring.kafka.consumer.heartbeat-interval.ms=3000spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializerspring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer

    4. 消息生产者-测试

    @RunWith(SpringJUnit4ClassRunner.class)@SpringBootTest(classes = ZoheVideoStructApplication.class)public class ZoheVideoStructApplicationTest {    @Autowired    private KafkaTemplate kafkaTemplate;    @Test    public void test(){        kafkaTemplate.send("sb_topic","123132132132132132123132132");    }}

    5. 消息消费者

    @Componentpublic class KafkaConsumer {    //监听消费    @KafkaListener(topics = {"sb_topic"},groupId = "test")    public void onNormalMessage(ConsumerRecord record) {        System.out.println("简单消费：" + record.topic() + "-" + record.partition() + "="+  record.value());    }    //监听消费    @KafkaListener(topics = {"sb_topic"},groupId = "test2")    public void onNormalMessage2(ConsumerRecord record) {        System.out.println("简单消费2：" + record.topic() + "-" + record.partition() + "=" + record.value());    }}

    三、启动测试

    四、有总结的不对的地方/或者问题 请指正, 我在努力中