kafka的一些常用命令
启动zookeeper
bin/zookeeper-server-start.sh config/zookeeper.properties &
启动kafka
bin/kafka-server-start.sh config/server.properties &
停止kafka
bin/kafka-server-stop.sh
停止zookeeper
bin/zookeeper-server-stop.sh
创建topic
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
展示topic
bin/kafka-topics.sh --list --zookeeper localhost:2181
描述topic
bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic my-replicated-topic
生产者:
bin/kafka-console-producer.sh --broker-list 130.51.23.95:9092 --topic my-replicated-topic
消费者:
bin/kafka-console-consumer.sh --zookeeper 130.51.23.95:2181 --topic test --from-beginnin
查看条数
./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic my-topic --time -1
删除话题
/kafka-topics.sh --zookeeper localhost:2181 --delete --topic my-topic
kafka的一些常用命令相关推荐
- kafka安装及常用命令
kafka是一个开源的分布式消息队列 他提供可靠的集群容错机制,并保证故障切换时的数据完整性. 无论从性能.可靠性.易用性都强过ActiveMQ(client的API感觉还是不如ActiveMQ好用, ...
- kafka 配置及常用命令
1. 主要配置 config/server.properties (1) broker.id=0 # 集群中,每个 kafka 实例的值都不一样 (2) log.dirs=/tmp/kafka-l ...
- Kafka学习笔记-常用命令
特性 高吞吐量.低延迟,kakka每秒可以处理几十万条消息,它的延迟最低只有几毫秒,每个主题可以分为多个分区,消费组可以对分区进行消费操作. 可扩展性:kafka集群支持热扩展 扩展性:可靠性,消费被 ...
- kafka安装、配置、启动、常用命令及shell启动脚本编写
config :kafka配置文件所在目录 server.properties 主要配置文件 zookeeper.properties kafka内置了zk,一般要将其替换掉 以下关于生产 ...
- kafka创建topic_一网打尽Kafka常用命令、脚本及配置,宜收藏!
前言 通过前面 7 篇文章的介绍,小伙伴们应该对 Kafka 运行工作原理有一个相对比较清晰的认识了. Kafka是什么?一起来看看吧! Kafka 安装及简单命令使用 Kafka中消息如何被存储到B ...
- kafka常用命令及问题解决
常用命令 Kafka内部提供了许多管理脚本,这些脚本都放在$KAFKA_HOME/bin目录下,而这些类的实现都是放在源码的kafka/core/src/main/scala/kafka/tools/ ...
- Kafka学习之四 Kafka常用命令
2019独角兽企业重金招聘Python工程师标准>>> Kafka学习之四 Kafka常用命令 Kafka常用命令 以下是kafka常用命令行总结: 1.查看topic的详细信息 . ...
- kafka java api 删除_Kafka入门系列—6. Kafka 常用命令及Java API使用
常用命令 启动Zookeeper ./zkServer.sh start-foreground 可选参数: ./zkServer.sh {start|start-foreground|stop|res ...
- Kafka常用命令(1):kafka-topics
Kafka常用命令之:kafka-topics 概述 1. 创建Topic: --create 2. 查看Topic详细信息: --describe 3. 查看Topic列表: --list 4.修改 ...
最新文章
- linux内核添加c代码,如何从C代码加载Linux内核模块?
- coba mysql_在Android Studio中将数据从MySQL数据库显示到TextView中-问答-阿里云开发者社区-阿里云...
- 【REST SOAP】REST和SOAP Web Service的区别比较
- webpack常用命令总结
- CyAPI.lib(CyAPI.obj) : error LNK2019: 无法解析的外部符号...
- 容易被PHP程序员忽视的几个要点
- 高中信息技术——Flash动画制作刷题点整理(二)
- stooge sort
- 没想明白:JAVA的char是2字节,如何实现18030的4字节?
- java 字符串索引从0开始_Java程序从指定的索引中搜索子字符串
- android 截图root权限,为什么 Android 截屏需要 root 权限
- QT5 Drilldown的柱状图
- 第十三届蓝桥杯C++B组国赛D题——最大数字(AC)
- 【数据分析与娱乐八卦】从Python可视化图表中探究王心凌出圈的流量密码
- 基于SSM框架的借阅图书管理系统
- 计算机上配置静态ip,如何给电脑设置固定IP地址
- 启动定时器t0的工作指令是_启动定时器T0工作,可使用SETB TR0启动。_学小易找答案...
- 那么浙江大学软件工程专业复试考试内容有哪些
- 记录一个因为使用masonry 布局造成的宽度不准确的问题
- Django 框架学习经验分享