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