首页 > 其他分享 >kafka消费者不能消费信息

kafka消费者不能消费信息

时间:2023-03-15 18:14:02浏览次数:41  
标签:__ 消费 消费者 offsets topics zookeeper kafka consumer

 

1、在kafka查看主题__consumer_offsets的情况

 

$kafka_home/bin/kafka-topics.sh --describe --zookeeper hostname:2181  --topic __consumer_offsets 

显示图片的结果,就是消费者的偏移存储有问题。

 

2、在zookeeper中删除主题__consumer_offsets

 

cd $zookeeper_home/bin

#进入zookeeper命令行环境

./zkCli.sh

#显示节点

ls /brokers/topics

#删除__consumer_offsets节点

rmr /brokers/topics/__consumer_offsets

 

3、重启kafka,可以在kafka中看到重新生成__consumer_offsets主题,并且改主题的leader不是-1。

 

4、使用kafka-consumer-console.sh测试消费消息。

 

标签:__,消费,消费者,offsets,topics,zookeeper,kafka,consumer
From: https://www.cnblogs.com/chubbyData/p/17219459.html

相关文章

  • nginx+lua+openresty+kafka相关问题汇总
    这里使用的是kafka插件是doujiang大佬的https://github.com/doujiang24/lua-resty-kafka,版本为v0.2.0。应用场景在nginx转发中,记录非200请求的信息,遂打算在log_by_lua*中......
  • kafka容器内的server.properties在哪里
    刚刚需要修改kafka的配置文件server.properties,网上都说在config目录下,可我进去kafka容器找了一圈都没有看到该目录; 最后运气好,终于发现了 ......
  • Kafka Rebalance-重平衡
    消费者组ConsumerGroupKafka提供的可扩展且具有容错性的消费者机制共享一个公共的ID,这个ID被称为GroupID。组内的所有消费者协调在一起来消费订阅主题(Subscribe......
  • Python对中国电信消费者特征预测:随机森林、朴素贝叶斯、神经网络、最近邻分类、逻辑回
    全文链接:http://tecdat.cn/?p=31868原文出处:拓端数据部落公众号分析师:ChangGao随着大数据概念的兴起,以数据为基础的商业模式越来越流行,用所收集到的因素去预测用户的可......
  • Kafka为什么性能这么快
    1、页缓存技术pagecacheKafka是基于操作系统的页缓存(pagecache)来实现文件写入的,我们也可以称之为oscache,意思就是操作系统自己管理的缓存。Kafka在写入磁盘文件......
  • docker安装kafka
    dockerrun-d--namezookeeper-p2181:2181-tzookeeper:latest  dockerrun-d--namekafka-p9092:9092-eKAFKA_BROKER_ID=0-eKAFKA_ZOOKEEPER_CONNEC......
  • Kafka、RabbitMQ、RocketMQ差异
    消息中间件消息中间件是分布式系统中重要的组件,本质就是一个具有接收消息、存储消息、分发消息的队列,应用程序通过读写队列消息来通信。在电商中,如订单系统处理完订单后,把订......
  • 生产者消费者设计模式
    publicclassDemo{/*生产者步骤:*1、判断桌子上是否有汉堡包*2、如果有就等待,如果没有,就生产*3、把生产的汉堡包放到桌子上*4、唤醒......
  • 3.docker 搭建kafka和kafka-manager集群
    1.搭建zookeeper集群docker-compose.yml文件version:'3.1'services:zoo1:image:zookeeperrestart:alwayshostname:zoo1ports:-2181:2181environment:ZOO_M......
  • kafka安装部署
    kafka安装部署 1、安装jdk(1)创建安装目录mkdir/usr/local/java(2)解压缩包到安装的目录下tar-zxvfjdk-8u51-linux-x64.tar.gz-C/usr/local/java/(3)修改环境变量v......