kafak 命令使用

本篇文章主要内容：

kafka常用命令总结

一.kafka常用命令总结：

1.创建topic

bin/kafka-topics.sh --create --zookeeper ip:port/chroot --replication-factor num --partitions num --topic topic-name
ip:port/chroot－> kafka的zookeeper地址num －> 数量topic-name －> topic的名称注：向kafka发送数据之前不一定要事先创建topic，可以直接指定topic发送数据。

2.向kafka发送数据

bin/kafka-console-producer.sh --broker-list broker-ip:port --topic topic-name
broker-ip:port －> broker地址注：执行完此命令，可以直接在终端输入数据，按回车键发送，ctrl－c退出。

3.从kafka读取数据

＃首先是跟读模式bin/kafka-console-consumer.sh --zookeeper ip:port/chroot --topic topic-name可以读取到实时发送到kafka的数据，不能读取到历史数据。＃从开始偏移量（offset）读取数据bin/kafka-console-consumer.sh --zookeeper ip:port/chroot --topic topic-name --from-beginning从topic起始位置开始读取。

4.查看kafkaz中 topic的列表

bin/kafka-topics.sh --list --zookeeper  ip:port/chroot

5.查看某一个topic的详细信息

bin/kafka-topics.sh --describe --zookeeper ip:port/chroot --topic topic-name

6. 查看topic的消费偏移量

bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper  ip:port/chroot --group group-name注：实际log消息数量和group下消费的偏移量都可以查看到

其它命令点击这里

转载于:https://www.cnblogs.com/wenchengxiaopenyou/p/5702820.html

kafak 命令使用相关推荐

kafka命令行操作
[README] kafka集群 -- kafka集群 3台机器 centos201 192.168.163.201 centos202 192.168.163.202 centos203 192.1 ...
kafak windows环境的简单测试笔记
1:进入到kafka目录下cmd指令,先运行zookeeper,: 运行:.\bin\windows\zookeeper-server-start.bat .\config\zookeeper.pro ...
Kafak快速入门攻略
前言:Kafak和RabbbitMQ技术选型?为什么Kakfa这么快?怎么保证Kakfa的消息顺序性?面试官三连问,这谁顶得住? 一.Kafka简介 1.1.Kafak概述 Kafka是由Linked ...
Kubectl 常用命令, 开发人员常用k8s命令
Kubectl 常用命令: 什么是常用,我用的,就是常用的
ECS（Linux）连接RDS，使用命令行方式连接实例
使用命令行方式连接实例通过命令行连接RDS MySQL数据库,连接方式如下: mysql -h<连接地址> -P<端口> -u<用户名> -p -D<数据库 ...
设置普通用户执行docker命令，执行docker命令无需输入密码或者切换root用户
每次执行docker命令都要输入密码或者切换root用户,非常不方便,尤其是在shell脚本中就更麻烦了,一起来解决这个问题: 1. 创建名为docker的组,如果之前已经有该组就会提示已存在: su ...
从命令行到IDE，版本管理工具Git详解（远程仓库创建+命令行讲解+IDEA集成使用）
首先,Git已经并不只是GitHub,而是所有基于Git的平台,只要在你的电脑上面下载了Git,你就可以通过Git去管理"基于Git的平台"上的代码,常用的平台有GitHub.Gi ...
作为一个java程序员，常用的linux命令（越攒越多）
本篇记录我在工作中不断遇到的常用的linux命令,并进行总结,时常更新! 1. 升级服务时先停止服务,然后进行替换 linux中杀进程时候,如果你是知道它所占用的端口号的话,可以通过 netstat ...
docker上你必须会的那些命令
一.基础类查看docker信息 # 查看docker版本 docker version # 显示docker系统的信息 docker info # 日志信息 docker logs # 故障检查 s ...

kafak 命令使用

一.kafka常用命令总结：

kafak 命令使用相关推荐

最新文章

热门文章