Kafka 常用命令记录

指令参数就不解释了，很容易看明白。

如果允许下指令create/delete topic, config 文件需要更改参数：

delete.topic.enable=true

auto.create.topics.enable=true

create topic

./kafka-topics.sh --create --zookeeper zk0:10199,zk1:10198,zk2:10197 --replication-factor 3 --partitions 3 --topic topicName

delete topic

./kafka-topics.sh --delete --zookeeper zk0:10199,zk1:10198,zk2:10197 --topic topicName

list topic

./kafka-topics.sh --describe --zookeeper zk0:10199,zk1:10198,zk2:10197

modify topic parameters

./kafka-topics.sh --zookeeper zk0:10199,zk1:10198,zk2:10197 --alter --partitions 3 --topic topicName

即：无论当前指定的topic中的partition有几个，最终改为3

consumer command

/kafka-console-consumer.sh --bootstrap-server kfk0:11199,kfk1:11198,kfk2:11197 --topic streams-wordcount-output --from-beginning \
--formatter kafka.tools.DefaultMessageFormatter \
--property print.key=true \
--property print.value=true \
--property key.deserializer=org.apache.kafka.common.serialization.StringDeserializer \
--property value.deserializer=org.apache.kafka.common.serialization.LongDeserializer

最简单的将log直接谢入kafka中。

tail -n 0 -f /var/log/xxxx.log | bin/kafka-console-producer.sh --broker-list kfk0:10199 --sync --topic topicName

kafka-console-producer.sh 参数很多，不一一列举了。

指令很多，好好利用一下bin下的工具。

转载于:https://www.cnblogs.com/ray30th/p/6652119.html

Kafka 常用命令记录相关推荐

ElasticSearch常用命令记录
ElasticSearch常用命令记录 < - 个人学习笔记 - > 软件版本:curl -s localhost:9200/?pretty 输出中"version" ...
Kafka学习之四 Kafka常用命令
2019独角兽企业重金招聘Python工程师标准>>> Kafka学习之四 Kafka常用命令 Kafka常用命令以下是kafka常用命令行总结: 1.查看topic的详细信息 . ...
Kafka常用命令（1）：kafka-topics
Kafka常用命令之:kafka-topics 概述 1. 创建Topic: --create 2. 查看Topic详细信息: --describe 3. 查看Topic列表: --list 4.修改 ...
Kafka常用命令行命令
文章目录 Kafka常用命令 kafka的基本操作(命令行操作) 1.启动集群: 2.查看当前服务器中的所有topic(在kafka目录下) 3.创建主题topic(在kafka目录下) 4.删除to ...
centos查看盘符_Centos下磁盘管理的常用命令记录（如查找大文件）
Centos下磁盘管理的常用命令记录查看系统磁盘空间占用,使用命令: df -h 结果: 查看磁盘inode使用情况,如果inode用完了,磁盘就没法写入新的内容了: df -i 结果: 如何查找磁 ...
kafka常用命令及问题解决
常用命令 Kafka内部提供了许多管理脚本,这些脚本都放在$KAFKA_HOME/bin目录下,而这些类的实现都是放在源码的kafka/core/src/main/scala/kafka/tools/ ...
kafka创建topic_一网打尽Kafka常用命令、脚本及配置，宜收藏！
前言通过前面 7 篇文章的介绍,小伙伴们应该对 Kafka 运行工作原理有一个相对比较清晰的认识了. Kafka是什么?一起来看看吧! Kafka 安装及简单命令使用 Kafka中消息如何被存储到B ...
kafka java api 删除_Kafka入门系列—6. Kafka 常用命令及Java API使用
常用命令启动Zookeeper ./zkServer.sh start-foreground 可选参数: ./zkServer.sh {start|start-foreground|stop|res ...
Kafka常用命令收录
目录目录 1 1. 前言 2 2. Broker默认端口号 2 3. 安装Kafka 2 4. 启动Kafka 2 5. 创建Topic 2 6. 列出所有Topic 3 7. 删除Topic 3 ...

Kafka 常用命令记录

Kafka 常用命令记录相关推荐

最新文章

热门文章