Kafka消费不到数据

7月前作者：wildding 分类：Toy博客阅读(26) 违法举报

这篇具有很好参考价值的文章主要介绍了Kafka消费不到数据。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

1.首先停止kafka： kafka.sh stop

2.查看/config/server.properties看logdir的目录，换个目录或者删除目录中的数据，本机是 rm -rf datas/* (注：kafka报错日志可以在 logs里 server.log查看)

两种方法：

方法1：登录bin/zkCli.sh 然后删除kafka中/brokers/topics/__consumer_offsets 节点

方法2：停止zookeeper： zk.sh stop 查看conf/zoo.cfg的dataDir的路径，删除目录中的数据（myid不要删了）(注：zookeeper报错日志可以在 logs里xxxx.out中查看)

尝试开启zk，kafka 开启生产者，消费者看能否传输和接收

Kafka目录下开启生产者：bin/kafka-console-producer.sh --bootstrap-server hadoop102:9092 --topic first

Kafka目录下开启生消费者：bin/kafka-console-consumer.sh --bootstrap-server hadoop102:9092 --topic first文章来源地址https://www.toymoban.com/news/detail-597508.html

到了这里，关于Kafka消费不到数据的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：如若内容造成侵权/违法违规/事实不符，请点击违法举报进行投诉反馈，一经查实，立即删除！

分享到：

领支付宝红包赞助服务器费用

分布式 - 消息队列Kafka：Kafka 消费者的消费位移

01. Kafka 分区位移对于Kafka中的分区而言，它的每条消息都有唯一的offset，用来表示消息在分区中对应的位置。偏移量从0开始，每个新消息的偏移量比前一个消息的偏移量大1。每条消息在分区中的位置信息由一个叫位移（Offset）的数据来表征。分区位移总是从 0 开始，假设一

2024年02月12日
浏览(35)
分布式 - 消息队列Kafka：Kafka消费者和消费者组

1. Kafka 消费者是什么？消费者负责订阅Kafka中的主题，并且从订阅的主题上拉取消息。与其他一些消息中间件不同的是：在Kafka的消费理念中还有一层消费组的概念，每个消费者都有一个对应的消费组。当消息发布到主题后，只会被投递给订阅它的每个消费组中的一个消费者

2024年02月13日
浏览(33)
分布式 - 消息队列Kafka：Kafka 消费者消息消费与参数配置

01. 创建消费者在读取消息之前，需要先创建一个KafkaConsumer对象。创建KafkaConsumer对象与创建KafkaProducer对象非常相似——把想要传给消费者的属性放在Properties对象里。为简单起见，这里只提供4个必要的属性：bootstrap.servers、key.deserializer 和 value.deserializer。 ① bootstrap.servers 指

2024年02月12日
浏览(31)
分布式 - 消息队列Kafka：Kafka 消费者消费位移的提交方式

最简单的提交方式是让消费者自动提交偏移量，自动提交 offset 的相关参数： enable.auto.commit：是否开启自动提交 offset 功能，默认为 true; auto.commit.interval.ms：自动提交 offset 的时间间隔，默认为5秒；如果 enable.auto.commit 被设置为true，那么每过5秒，消费者就会自动提交 poll() 返

2024年02月12日
浏览(32)
记一次element-ui的table不显示，也不报错的问题

vue版本：2.6.14 element-ui版本：2.15.13 element-ui 的table组件，死活不显示表头，给数据的话整个就空白，不给数据就只显示一个 “暂无数据”，控制台也不报错，降版本也不行找了半天的原因，甚至重建新项目，最终排查的原因是 vue.config.js 下面的这段代码出了问题。原因未知

2024年02月11日
浏览(51)
SqlServer插入数据不报错但查询不到数据

近日，某使用SqlServer作为数据库的系统，由于服务器磁盘损坏修复后，部分数据一直无法入库，进一步跟踪收集现象，发现以下特点：这些数据抽取出来使用SQL直接入库，没有提示数据影响行数，数据库无法查询到这部分数据； JDBC入库返回影响行数为-2；仅有部分数据无法

2024年02月12日
浏览(46)
kafka-python 消费者消费不到消息

使用 group_id=”consumer_group_id_001“ 和 auto_offset_reset=\\\"earliest\\\" 生产者发完消息后，在close中先执行 producer.flush() ，再执行 producer.close() 使用offset 观看消息是否写到kafka中。

2024年02月10日
浏览(28)
分布式 - 消息队列Kafka：Kafka消费者的分区分配策略

Kafka 消费者负载均衡策略？ Kafka 消费者分区分配策略？ 1. 环境准备创建主题 test 有5个分区，准备 3 个消费者并进行消费，观察消费分配情况。然后再停止其中一个消费者，再次观察消费分配情况。 ① 创建主题 test，该主题有5个分区，2个副本： ② 创建3个消费者CustomConsu

2024年02月13日
浏览(32)
分布式 - 消息队列Kafka：Kafka消费者分区再均衡(Rebalance)

01. Kafka 消费者分区再均衡是什么？消费者群组里的消费者共享主题分区的所有权。当一个新消费者加入群组时，它将开始读取一部分原本由其他消费者读取的消息。当一个消费者被关闭或发生崩溃时，它将离开群组，原本由它读取的分区将由群组里的其他消费者读取。分区

2024年02月12日
浏览(27)
分布式消息队列Kafka（四）- 消费者

1.Kafka消费方式 2.Kafka消费者工作流程（1）总体工作流程（2）消费者组工作流程 3.消费者API （1）单个消费者消费实现代码（2）单个消费者指定分区消费代码实现：（3）消费者组消费复制上面CustomConsumer三个，同时去订阅统一个主题，消费数据，发现一个分区只能被一个

2023年04月26日
浏览(36)