kafka查看topic列表和topic消息

查询topic 列表信息
前提是需要进入到kafka的目录
Linux
目录 \kafka_2.12-2.8.0\bin\

sh kafka-topics.sh --list --zookeeper localhost:2181

windows
目录 \kafka_2.12-2.8.0\bin\windows

kafka-topics.bat --list --zookeeper localhost:2181

window下执行截图

查看topic的详细情况
linux

./kafka-topics.sh --describe --zookeeper localhost:2181 --topic test

windows

kafka-topics.bat --describe --zookeeper localhost:2181 --topic topic.test

返回结果信息（基本topic信息和分区信息）

更改top分区数量，只能增加不能减少
linux

./kafka-topics.sh --alter --zookeeper localhost:2181 --topic test --partitions 5

windows

kafka-topics.bat --alter --zookeeper localhost:2181 --topic topic.test --partitions 9

效果图

查看topic的消息列表
linux

sh kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topicName --from-beginning

window

kafka-console-consumer.bat  --bootstrap-server localhost:9092 --topic topic.test --from-beginning

window执行结果截图

kafka查看topic列表和topic消息相关推荐

kafka消费之kafka查看topic是否有数据
配置config文件为:server.properties 脚本在 kafka/bin路径下启动kafka: ./kafka-server-start.sh ../config/server.pro ...
查看当前服务器中的所有的topic，创建topic,删除topic,通过shell命令发送消息，通过shell消费消息，查看topic详情,对分区数进行修改
一. Kafka常用操作命令  查看当前服务器中的所有topic [root@hadoop3 kafka]# bin/kafka-topics.sh --list --zookeeper hadoo ...
Kafka Java consumer动态修改topic订阅
前段时间在Kafka QQ群中有人问及此事--关于Java consumer如何动态修改topic订阅的问题.仔细一想才发现这的确是个好问题,因为如果简单地在另一个线程中直接持有consumer实例然 ...
kafka集群选择多少topic和partition最合适
1. partition越多吞吐量越大首先我们需要明白以下事实:在kafka中,单个patition是kafka并行操作的最小单元.在producer和broker端,向每一个分区写入数据是可以完全 ...
【Kafka】命令行管理topic
Kafka版本: 1.0.1 1. 创建topic [hadoop@node03 bin]$ kafka-topics.sh --create --partitions 3 --replication ...
kafka实现异步发送_Kafka 异步消息也会阻塞？记一次 Dubbo 频繁超时排查过程
线上某服务 A 调用服务 B 接口完成一次交易,一次晚上的生产变更之后,系统监控发现服务 B 接口频繁超时,后续甚至返回线程池耗尽错误 Thread pool is EXHAUSTED.因为服务 B ...
kafka消费者如何读同一生产者消息_Kafka入门之生产者消费者
一.Kafka安装与使用 ( kafka介绍 ) 1. 下载Kafka 2. 安装 Kafka是使用scala编写的运行与jvm虚拟机上的程序,虽然也可以在windows上使用,但是kafka ...
kafka消费者如何读同一生产者消息_Kafka系列3：深入理解Kafka消费者
上面两篇聊了Kafka概况和Kafka生产者,包含了Kafka的基本概念.设计原理.设计核心以及生产者的核心原理.本篇单独聊聊Kafka的消费者,包括如下内容:消费者和消费者组如何创建消费者如何消 ...
Kafka详解（上）——消息系统分类、Kafka安装、两种启动、基本概念、两种架构、核心配置文件
1 消息和消息系统消息(Message)是指在应用间传送的数据.消息可以非常简单,比如只包含文本字符串,也可以更复杂,可能包含嵌入对象. 1-1 消息系统是什么消息系统负责将数据从一个应用 ...

kafka查看topic列表和topic消息

kafka查看topic列表和topic消息相关推荐

最新文章

热门文章