有没有kafka命令行的所有命令列表，急需？

忘南忘北不忘你

显示所有消息属性

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my-topic --property print.key=true --property print.value=true --property print.partition=true --property print.offset=true --property print.timestamp=true --property key.separator=":" --property line.separator="\n"

发布于：2个月前 (03-06) IP属地：

有你我就幸福

设置消费超时

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my-topic --timeout-ms 10000

发布于：2个月前 (03-06) IP属地：

孤岛少女情

使用消费者组

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my-topic --group my-group

发布于：2个月前 (03-06) IP属地：

娇喘界的扛把子

指定offset消费

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my-topic --partition 0 --offset 1000

发布于：2个月前 (03-06) IP属地：

原来无话可说

指定分区消费

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my-topic --partition 0

发布于：2个月前 (03-06) IP属地：

丶殇

显示offset信息

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my-topic --property print.offset=true

发布于：2个月前 (03-06) IP属地：

鹿隐林间べ心随影动

显示分区信息

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my-topic --property print.partition=true

发布于：2个月前 (03-06) IP属地：

青山依旧

显示消息的时间戳

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my-topic --property print.timestamp=true

发布于：2个月前 (03-06) IP属地：

小xの碎碎念

显示消息的key

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my-topic --property print.key=true --property key.separator=":"

发布于：2个月前 (03-06) IP属地：

一心居一人

从头开始消费

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

发布于：2个月前 (03-06) IP属地：

ε小可爱з

基本消费命令，从最新位置开始消费消息

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my-topic

发布于：2个月前 (03-06) IP属地：

那句晚安你听了吗

高性能配置

kafka-console-producer.sh --bootstrap-server localhost:9092 --topic my-topic --producer-property batch.size=65536 --producer-property linger.ms=20 --producer-property compression.type=lz4

发布于：2个月前 (03-06) IP属地：

ε小可爱з

高可靠性配置

kafka-console-producer.sh --bootstrap-server localhost:9092 --topic my-topic --producer-property acks=all --producer-property min.insync.replicas=2 --producer-property enable.idempotence=true

发布于：2个月前 (03-06) IP属地：

沐叶清风

发送带时间戳的消息

kafka-console-producer.sh --bootstrap-server localhost:9092 --topic my-topic --property "parse.key=true" --property "key.separator=:" --property "timestamp.type=CreateTime"

发布于：2个月前 (03-06) IP属地：

你是我此生最美的风景

指定生产者配置

kafka-console-producer.sh --bootstrap-server localhost:9092 --topic my-topic --producer-property acks=all --producer-property batch.size=16384 --producer-property linger.ms=1

发布于：2个月前 (03-06) IP属地：

披起头发是娇弱

同步发送消息

kafka-console-producer.sh --bootstrap-server localhost:9092 --topic my-topic --sync

发布于：2个月前 (03-06) IP属地：

回忆多美好

带消息属性的生产

kafka-console-producer.sh --bootstrap-server localhost:9092 --topic my-topic --property "parse.key=true" --property "key.separator=:" --property "compression.type=gzip"

发布于：2个月前 (03-06) IP属地：

候你多时

批量从文件读取消息

kafka-console-producer.sh --bootstrap-server localhost:9092 --topic my-topic < messages.txt

发布于：2个月前 (03-06) IP属地：

孤居

指定分区生产消息

kafka-console-producer.sh --bootstrap-server localhost:9092 --topic my-topic --property partition=0

发布于：2个月前 (03-06) IP属地：

安若兮

带key的消息生产，使用tab分隔符分隔key和value

kafka-console-producer.sh --bootstrap-server localhost:9092 --topic my-topic --property parse.key=true --property key.separator="\t"

发布于：2个月前 (03-06) IP属地：

时光静好べ与君语

基本生产消息命令，最简单的生产消息方式，输入消息后按回车发送，按Ctrl+C退出

kafka-console-producer.sh --bootstrap-server localhost:9092 --topic my-topic

发布于：2个月前 (03-06) IP属地：

最后一丝温柔

查看集群ACL

kafka-acls.sh --bootstrap-server localhost:9092 --list

发布于：2个月前 (03-06) IP属地：

相视而笑

查看集群健康状态

kafka-cluster.sh --bootstrap-server localhost:9092 --health

发布于：2个月前 (03-06) IP属地：

青山依旧

查看集群元数据

kafka-metadata-shell.sh --bootstrap-server localhost:9092

发布于：2个月前 (03-06) IP属地：

心似狂潮

查看集群分区分配

kafka-cluster.sh --bootstrap-server localhost:9092 --describe --entity-type partitions

发布于：2个月前 (03-06) IP属地：

酷味有余

删除动态配置

kafka-configs.sh --bootstrap-server localhost:9092 --entity-type brokers --entity-name 0 --alter --delete-config "log.retention.hours"

发布于：2个月前 (03-06) IP属地：

思念是一种病

查看动态配置

kafka-configs.sh --bootstrap-server localhost:9092 --entity-type brokers --entity-name 0 --describe

发布于：2个月前 (03-06) IP属地：

与风为伴

修改集群配置

kafka-configs.sh --bootstrap-server localhost:9092 --entity-type brokers --entity-name 0 --alter --add-config "log.retention.hours=168"

发布于：2个月前 (03-06) IP属地：

鹿鸣山谷べ心相随

查看集群配置

kafka-cluster.sh --bootstrap-server localhost:9092 --describe --entity-type brokers --entity-default

发布于：2个月前 (03-06) IP属地：

樱花下的编程者

查看broker信息，显示指定broker的详细信息

kafka-cluster.sh --bootstrap-server localhost:9092 --describe --entity-type brokers --entity-name 0

发布于：2个月前 (03-06) IP属地：

流年似水べ梦未央

查看集群控制器信息，显示当前的控制器(Controller)节点信息

kafka-cluster.sh --bootstrap-server localhost:9092 --describe --entity-type controller

发布于：2个月前 (03-06) IP属地：

我怕时间不够i

查看集群状态，显示所有broker的状态信息

kafka-cluster.sh --bootstrap-server localhost:9092 --describe

发布于：2个月前 (03-06) IP属地：

孑身一人

查看集群中的broker列表

kafka-broker-api-versions.sh --bootstrap-server localhost:9092

发布于：2个月前 (03-06) IP属地：

咪有了

查看主题的详细指标命令示例：

kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic my-topic --report-detailed

发布于：2个月前 (03-06) IP属地：

帅的很低调

批量查看多个主题的命令示例：

kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic "topic1,topic2,topic3"

发布于：2个月前 (03-06) IP属地：

ε小可爱з

查看没有leader的分区的命令示例：

# --unavailable-partitions: 显示所有没有leader的分区
kafka-topics.sh --describe --bootstrap-server localhost:9092 --unavailable-partitions

发布于：2个月前 (03-06) IP属地：

冷言冷语冷眼相对

查看未同步的副本的命令示例：

# --under-replicated-partitions: 显示所有未完成同步的分区
kafka-topics.sh --describe --bootstrap-server localhost:9092 --under-replicated-partitions

发布于：2个月前 (03-06) IP属地：

我怕时间不够

查看主题的分区副本分配情况的命令示例：

# --topics-with-overrides: 显示所有配置被覆盖的主题
kafka-topics.sh --describe --bootstrap-server localhost:9092 --topics-with-overrides

发布于：2个月前 (03-06) IP属地：

ε小可爱з

删除主题配置的示例命令：

# --delete-config: 删除配置项
kafka-configs.sh --alter --bootstrap-server localhost:9092 --entity-type topics --entity-name my-topic --delete-config retention.ms

发布于：2个月前 (03-06) IP属地：

孤岛少女情

修改主题配置的命令示例：

# --alter: 修改配置
# --add-config: 添加或修改配置
kafka-configs.sh --alter --bootstrap-server localhost:9092 --entity-type topics --entity-name my-topic --add-config retention.ms=86400000

发布于：2个月前 (03-06) IP属地：

我怕时间不够

查看主题的配置覆盖的命令示例：

# --describe: 查看配置
# --entity-type: 实体类型(topics)
# --entity-name: 主题名称
kafka-configs.sh --describe --bootstrap-server localhost:9092 --entity-type topics --entity-name my-topic

发布于：2个月前 (03-06) IP属地：

♀如此美

查看特定分区的详情的命令示例：

# --topic: 指定主题
# --partition: 指定分区
kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic my-topic --partition 0

发布于：2个月前 (03-06) IP属地：

渡不过的奈何桥

创建带配置的主题命令示例

# --config: 指定主题级别的配置
kafka-topics.sh --create --bootstrap-server localhost:9092 --topic configured-topic --partitions 4 --replication-factor 2 --config cleanup.policy=delete --config retention.ms=604800000 --config segment.bytes=1073741824

发布于：2个月前 (03-06) IP属地：

我心已凉

自定义副本分配创建主题的命令示例：

# --replica-assignment: 手动指定分区副本分配方案
# 格式: "broker_id:broker_id,broker_id:broker_id"
kafka-topics.sh --create --bootstrap-server localhost:9092 --topic custom-topic --replica-assignment "1:2,2:3,3:1"

发布于：2个月前 (03-06) IP属地：

一闪一闪亮晶晶べ

删除主题的命令示例：

# --delete: 删除主题
kafka-topics.sh --delete --bootstrap-server localhost:9092 --topic my-topic

发布于：2个月前 (03-06) IP属地：

旧梦难醒

增加分区数的命令示例：

# --alter: 修改主题配置
# --partitions: 新的分区数(只能增加不能减少)
kafka-topics.sh --alter --bootstrap-server localhost:9092 --topic my-topic --partitions 8

发布于：2个月前 (03-06) IP属地：

少女榨汁机

查看主题详情的命令示例：

# --describe: 查看主题详细信息
# --topic: 指定主题名称
kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic my-topic

发布于：2个月前 (03-06) IP属地：

我是白云

列出所有主题的命令示例：

# --list: 列出所有主题
kafka-topics.sh --list --bootstrap-server localhost:9092

发布于：2个月前 (03-06) IP属地：

浮°

创建主题的命令示例

# --create: 创建主题
# --bootstrap-server: 指定Kafka服务器地址
# --topic: 主题名称# --partitions: 分区数
# --replication-factor: 副本因子
kafka-topics.sh --create --bootstrap-server localhost:9092 --topic my-topic    --partitions 4 --replication-factor 2

发布于：2个月前 (03-06) IP属地：