文档章节

kafka常用命令

EveryDayNew
 EveryDayNew
发布于 2017/04/08 18:02
字数 99
阅读 7
收藏 0

http://www.importnew.com/24973.html

http://www.mamicode.com/info-detail-632293.html

1、启动命令:sh kafka-server-start.sh -daemon ../config/server.properties

2、查看topic列表:./kafka-topics.sh --zookeeper localhost:2181 --describe

3、创建topic,--replication-factor表示复制到多少个节点,--partitions表示分区数:

./kafka-topics.sh --zookeeper localhost:2181 --create --topic topic1 --replication-factor 1 --partitions 1

4、发送消息:

./kafka-console-producer.sh --broker-list localhost:9092 --topic topic1

5、消费消息:

./kafka-console-consumer.sh --zookeeper localhost:2181 --topic topic1

6、kafka节点检查

./kafka-replica-verification.sh --broker-list localhost:9092

© 著作权归作者所有

共有 人打赏支持
EveryDayNew
粉丝 5
博文 45
码字总数 31409
作品 0
杭州
程序员

暂无文章

js实现产生n个随机数,并且随机数之和是固定值

function getrandom(minnum , maxnum ,total,size){ var num = total; //定义整数 var length= size; //定义多个整数的数量 var numArr = []; while(length > 1){ var rnd = Math.floor(Mat......

开源昕昕
29分钟前
2
0
精选Spring Boot三十五道必知必会知识点!

Spring Boot 是微服务中最好的 Java 框架. 我们建议你能够成为一名 Spring Boot 的专家。本文精选了三十五个常见的Spring Boot知识点,祝你一臂之力! 问题一 Spring Boot、Spring MVC 和 Sp...

Java填坑之路
31分钟前
2
0
MyBatis学习笔记

相关文档 mybatis深入理解(一)之 # 与 $ 区别以及 sql 预编译 MyBatis 处理sql中的 大于,小于,大于等于,小于等于

OSC_fly
31分钟前
0
0
Gradle从不同地方复制文件到一个文件夹/打zip包

复制 task copySDK(type: Copy, dependsOn: [":fatJarTask"]) { delete JAR_NAME delete SDK_OUT_PATH delete "$ROOT_BUILD_PATH/$SDK_ZIP_NAME" into('/jniLibs') {......

SuShine
31分钟前
1
0
CentOS关闭占用端口,修改Apache默认端口,并重启Apache

查找并关闭进程 在Linux系统中可以使用lsof命令和kill命令,两个命令配合查找并关闭占用端口的进程 查看某一端口使用情况的命令: lsof -i:端口号 效果如下,PID即进程的ID 根据PID关闭进程,...

临江仙卜算子
38分钟前
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部