繁
全部 面试刷题 微服务 数据库 消息队列 搜索引擎 大数据 运维 go语言 人工智能

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

提问者：Rae 问题分类：消息队列
有没有kafka命令行的所有命令列表，急需？
Kafka
发布于：2周前 (03-06) IP属地：
49 个回答
忘南忘北不忘你
忘南忘北不忘你
显示所有消息属性
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の碎碎念
小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
我怕时间不够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属地：
我来回答