参考kafka官方文档，版本1.0.x
1 | http://kafka.apache.org/10/documentation.html#consumerapi |
依赖，选择 Cloudera Rel 中的 1.0.1-kafka-3.1.0
1 | <dependency> |
Kafka的消费者有2套API，一个是新版的Java API，在 org.apache.kafka.clients 包中
1 | http://kafka.apache.org/10/documentation.html#newconsumerconfigs |
一个是旧版的Scala API，在 kafka.consumer 包中
1 | http://kafka.apache.org/10/documentation.html#oldconsumerconfigs |
其中new consumer api中文含义参考
1 | https://tonglin0325.github.io/xml/kafka/1.0.1-kafka-3.1.0/new-consumer-api.xml |
kafka consumer参数调优：kafka consumer 参数调优
Kafka消费者不是线程安全的。所有的网络I/O都发生在进行调用的应用程序的线程中。用户有责任确保多线程访问是正确同步的。
