【README】

本文主要用于描述 kafka 消费者如何从头开始消费；

【1】从头开始消费

1）从头开始消费，需要满足两个条件，如下：

条件1，使用一个全新的消费者组id；
条件2，指定 auto.offset.reset 为 earliest ；

2）代码如下：

public static void main(String[] args) {/* 1.创建消费者配置信息 */Properties props = new Properties();/*2.给配置信息赋值*//*2.1连接的集群*/props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "centos201:9092");/*2.2开启自动提交 */props.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, true);/*2.3 自动提交的延时*/props.put(ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG, "1000");/*2.4 key value的反序列化 */props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());/*2.5 消费者组 */props.put(ConsumerConfig.GROUP_ID_CONFIG, "sichuan2"); // group.id /*2.6 重置消费者的offset */ props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest"); // 默认值是 lastest /* 创建消费者 */KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props); /* 订阅主题 */consumer.subscribe(Arrays.asList("third", "second"));/* 循环拉取 */ int i =0;while(true) {if (i++ > 10) break; // 只消费10条数据 /* 消费消息-获取数据 */ConsumerRecords<String, String> consumerRds  = consumer.poll(100);/* 解析并打印 ConsumerRecords  *//* 遍历 ConsumerRecords*/for(ConsumerRecord<String, String> rd : consumerRds) {System.out.println("[消费者] " + rd.key() + "--" + rd.value()); }} /* 关闭消费者 */ consumer.close(); }

kafak消费者从头开始消费（消费者组）相关推荐

kafka消费者如何才能从头开始消费某个topic的全量
消费者要从头开始消费某个topic的全量数据,需要满足2个条件(spring-kafka): (1)使用一个全新的"group.id"(就是之前没有被任何消费者使用过); (2)指 ...
5.3.4 消费组稳定后，原有消费者重新加入消费组
5.3.4 消费组稳定后,原有消费者重新加入消费组协调者在处理消费者发送的"加入组请求"和"同步组请求"时,都会依赖于消费组当前的状态进入不同的分支流程.假设 ...
5.3.5 消费组未稳定，原有消费者重新加入消费组
5.3.5 消费组未稳定,原有消费者重新加入消费组再来看另一种场景:其他消费者发送"加入组请求"先于第一个消费者发送"同步组请求".协调者返回"加入 ...
消费者详解-消费消息(1)
文章目录消费者消费消息流程 Pull消费流程 1. 初始化消费者 2. 拉取topic的消息队列 3. 拉取消费位点 4. 根据消费位点消费消息 5. 保存消费进度拉取消息-pullKernelI ...
Kafka多个消费者监听消费同一个Topic主题
多个消费者监听消费同一个Topic主题一.需求介绍二.@kafkaListener注解三.代码实现 3.1 第一个消费者 3.2 第二个消费者 3.3 生产者四.测试一.需求介绍有一个To ...
昨晚，我们的消费者居然停止消费kafka集群数据了
以下文章来源方志朋的博客,回复"666"获面试宝典图片来源:伪装者来源 | https://juejin.im/post/6874957625998606344 笔者所在的是一 ...
2022中国可持续消费报告：近半数消费者将月度消费2-5成用于低碳产品 | 美通社头条...
美通社消息:<2022中国可持续消费报告>正式发布.该报告是商道纵横与界面新闻第七年联合推出的调研报告. 低碳知多少报告显示,近一年政府对"双碳"目标的宣传和普及效果 ...
使用Disruptor完成多个消费者不重复消费消息
上一篇https://blog.csdn.net/tianyaleixiaowu/article/details/79787377里讲了Disruptor完成多个消费者并行.顺序重复消费Event.重 ...
消费者理论：消费集与偏好关系
文章目录消费集与偏好关系消费集偏好(Preference)及其表述消费者偏好的三个公理(理性假设) 无差异曲线消费者理性偏好的性质边际替代率参考消费集与偏好关系消费集消费集代表所有 ...

kafak消费者从头开始消费（消费者组）

【README】

【1】从头开始消费

kafak消费者从头开始消费（消费者组）相关推荐

最新文章

热门文章