【文件属性】：
文件名称：kafka-example:卡夫卡的例子
文件大小：15KB
文件格式：ZIP
更新时间：2021-05-16 09:41:19
kafka spring-kafka Java
读我
kafka学习代码。
基础
代码：
消费者：com.example.kafka.consumer
生产者：com.example.kafka.producer
其中消费者均为单线程消费，分为手动提交、自动提交两个版本。
在生产下，肯定是多消费者（不管是多线程还是多进程）。
多线程
生产者
由于生产者是线程安全的，因此，更推荐一个生产者实例，多线程引用进行生产的方式。这种方式通常要比每个线程维护一个KafkaProducer实例效率要高。
消费者
对于KafkaConsumer而言，它不是线程安全的，所以实现多线程时通常由两种实现方法：
每个线程维护一个KafkaConsumer
维护一个或多个KafkaConsumer，并用一个任务线程池处理任务
优缺点分析：
方法一：实现简单（即把之前的消费对象new几个就完了）。但是消费者线程处理任务容易超时，导致rebalance。
方法二：实
【文件预览】：
kafka-example-master
----src()
--------test()
--------main()
----pom.xml(2KB)
----.gitignore(21B)
----readme.md(7KB)