查看kafka的topic清单以及topic的内容
对于云端服务器上运行着的kafka集群,由于没有开放相关的端口,之前查看都是使用端口转发,ssh练上去之后,使用端口转发,转发到本地查看。
使用kafka时发现,zk连接上之后,里面的Brokers其实是云端服务器的内网,但是kafka tools会直接认为那些ip是本地ip,就会看不到kafka里面的内容。
试来试去,没找到合适的方法解决。如果有谁知道怎么弄,还请告诉我一声,非常感谢~
回到标题:
先进入容器,然后执行相关命令查看
cd bin/
查看kafka中topic清单:kafka-topics.sh --list --zookeeper [Server]:2181
查看某个topic内容:kafka-console-consumer.sh --bootstrap-server [Server]:9092 --from-beginning --topic [TopicName]
查看kafka的topic清单以及topic的内容相关推荐
- python 查看kafka发送的消息格式及消息内容
from pykafka import KafkaClientclient = KafkaClient(hosts="0.0.0.0:9092") topic = client.t ...
- 查看当前服务器中的所有的topic,创建topic,删除topic,通过shell命令发送消息,通过shell消费消息,查看topic详情,对分区数进行修改
一. Kafka常用操作命令 查看当前服务器中的所有topic [root@hadoop3 kafka]# bin/kafka-topics.sh --list --zookeeper hadoo ...
- 【Kafka】命令行管理topic
Kafka版本: 1.0.1 1. 创建topic [hadoop@node03 bin]$ kafka-topics.sh --create --partitions 3 --replication ...
- kafka命令行操作,topic相关命令
查看当前服务器中的所有topic: bin/kafka-topics.sh --zookeeper 主机:2181 --list 创建topic: bin/kafka-topics.sh --zook ...
- linux查看kafka队列消息,Kafka消息队列-从开始到上线
运行环境 操作系统:Windows 10 : Linux发行版:CentOS Linux release 7.6.1810 (Core) JDK版本:1.8.0_221 说在前面 kafka作为开源的 ...
- linux查看数据积压,查看kafka消息队列的积压情况
创建topic kafka-topics --create --zookeeper master:2181/kafka2 --replication-factor 2 --partitions 3 - ...
- 怎么查kafka版本在linux,查看kafka基本信息命令
将miner-profit topic副本由一个增加到3个 replication.json { "version": 1, "partitions": [ { ...
- kafka 统计消息总数_查看kafka消息队列的积压情况
创建topic kafka-topics --create --zookeeper master:2181/kafka2 --replication-factor 2 --partitions 3 - ...
- linux如何查看kafka消息队列,kafka以及消息队列详解
kafka以及消息队列详解 Kafka 是LinkedIn 开发的一个高性能.分布式的消息系统. 用途:广泛用于日志收集.流式数据处理.在线和离线消息分发等场景. 1. Kafka 将消息流按Topi ...
最新文章
- 21世纪科技生态面临第三次全球标准
- 什么?强化学习竟然来源于心理学?
- 北区首届科技文化潮流节启幕!诚邀科技企业参展,共同打造海淀北部最大科技“party”...
- 计算机二级在学校报还是外面报好,谁知道考计算机二级在哪个学校比较好啊?...
- python网上编程课程-少儿编程 为你解读Python编程课程
- 计算机视觉开源库OpenCV之边缘检测cv2.canny()函数
- php偷取,PHP偷取UTF-8目标网页内容输出为空白
- OO实现ALV TABLE 八:ALV的布局功能
- 百练162:Post Office
- python 安装第三方包
- C++成员函数指针的应用
- 3.js模式-策略模式
- 《JavaScript核心技术》
- spring bean生命周期_Spring中bean的生命周期和扩展点有哪些?
- [MS评估文档]SharePoint Portal Server 2003 的 10 大优点
- mysql的时间在cmd的输入格式_获取“System.FormatException:输入字符串的格式不正确。”在日期时间对象插入到MySql数据库...
- python教程-Python快速教程
- java实现simhash算法
- Oracle客户端配置
- 注册(六)之有效期过小