Java实现Kafka生产者和消费者的示例

Kafka简介Kafka是由Apache软件基金会开发的一个开源流处理平台，由Scala和Java编写。Kafka的目标是为处理实时数据提供一个统一、高吞吐、低延迟的平台。引入依赖在pom.xml文件中，引入spring-kafka依赖：在application.yml文件中增加配置：在Controller中注入KafkaTemplate就可以直接使用了，代码如下：在application.yml文件中增加配置：创建一个可以被Spring框架扫描到的类，并且在方法上加上@KafkaListener注解，就可以消费消息了，代码如下：