Skip to content

Latest commit

 

History

History
18 lines (9 loc) · 606 Bytes

README.md

File metadata and controls

18 lines (9 loc) · 606 Bytes

kafka-consumer-demo

这个项目意在演示,在kafka分区无法增加的情况下,通过使用线程池来提升消费能力

!!!需特别注意,多线程下很难保证消费的顺序,如果对消费有严格顺序要求的慎用

####需要JDK1.8以上环境

1.本机安装kafka,官方安装手册:https://kafka.apache.org/quickstart

2.下载源码,导入IDE

3.运行kafka-consumer模块下的KafkaConsumerApplication类接收消息

4.运行kafka-producer模块下的KafkaProducerApplication类推送消息

5.到kafka-consumer的控制台观察结果