Spring整合Kafka

• 引入依赖

  • spring-kafka

• 配置Kafka

  • 配置server，consumer

• 访问Kafka

  • 生产者：kafkaTemplate.send(topic, data);
  • 消费者：

  ​ @KafkaListener(topics = {“test”})

  ​ public void handleMessage(ConsumerRecord record) {}