首页 > TAG信息列表 > kafkaConsumer
Kafka多线程开发消费者实例
Kafka consumer是单线程的设计，这个其实不准确，从 Kafka 0.10.1.0 版本开始，KafkaConsumer 就变为了双线程的设计，即用户主线程和心跳线程。 所谓用户主线程，就是你启动 Consumer 应用程序 main 方法的那个线程，而新引入的心跳线程（Heartbeat Thread）只负责定期给对应的 Broker 机器发送心Kafka 消费者（二）
1、offset位移 1.1、offset的默认维护位置 从0.9版本开始，consumer默认将offset保存在Kafka一个内置的topic中，该topic为__consumer_offsets，Kafka0.9版本之前，consumer默认将offset保存在Zookeeper中 __consumer_offsets主题里面采用key和value的方式存储数据。key是group.id+topic+