首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往
您找到你想要的搜索结果了吗?
是的
没有找到

kafka查看消费数据

一、如何查看 在老版本中,使用kafka-run-class.sh 脚本进行查看。...但是对于最新版本kafka-run-class.sh 已经不能使用,必须使用另外一个脚本才行,它就是kafka-consumer-groups.sh 普通版 查看所有组 要想查询消费数据,必须要指定组...查看消费情况 bin/kafka-consumer-groups.sh --describe --bootstrap-server kafka-1.default.svc.cluster.local:9092...注意:以kafkaspout类作为消费者去读kafka数据,相当于直接从kafka server上取文件,没有消费者组的概念 每次读的数据存在自己zk的offet中,所以不能通过上述命令查看 ACL版查看...如果kafka启用了acl权限验证,则不能直接使用上面的命令查看,需要增加参数--command-config参数才行 此参数必须要指定一个配置文件才行 修改默认的配置文件 cd /kafka_2.12

6.3K10

mysql查看版本sql_linux查看mysql版本

【使用命令行查看mysql版本-直接查看】:在命令行输入“mysql–version",按”Enter“键即可....【使用命令行查看mysql版本-mysql变量查看】:在命令行输入“mysql",按”Enter“进入mysql命令行模式,输入”showvariableslike’version’;“即可....查看版本信息#1使用命令行模式进入mysql会看到最开始的提示符YourMySQLconnectionidis3Serverversion:5.1.69Sourcedistribution#2命令行中使用...status可以看到 1、使用-V参数首先我们想到的肯定就是查看版本号的参数命令,参数为-V(大写字母)或者–version使用方法:D:\xampp\mysql\bin>mysql-V或者D:\xampp...\mysql\bin> 查看mysql版本方法一:status;方法二:selectversion(); 一般情况下,mysql会默认提供多种存储引擎,你可以通过下面的查看:看你的mysql现在已提供什么存储引擎

21K10

kafka 查看topic offset_kafka重置offset

版本信息 Kafka 0.8.2,JDK1.7 问题现象 最近我们在生产环境执行删除无用的kafka topic的操作时,因为错误的按照8.2版本之前的删除方式操作8.2.2版本kafka,导致删除过程异常...0.8.2版本之前,kafka删除topic的功能存在bug,即无法通过kafka-topics –delete一条命令就彻底删除topic数据,这个命令只会在zookeeper中注销topic信息,...但是在0.8.2版本中,删除topic的操作经过优化,只需要两步就可以彻底删除topic所有数据,即配置并生效delete.topic.enable=true,然后执行kafka-topics –delete...所以,当我们在生产环境按照0.8.1版本的操作方式去删除0.8.2版本的topic时就会出现异常,因为在执行完kafka-topics –delete命令后,topic的状态已经被改变,同时broker...我们测试环境和生产环境的kafka版本都是0.8.2,但是在测试环境测试删除操作时,只删除了一个topic,产生的影响较小,所以错误操作的影响并没有表现出来。

98310
领券