Apache Kafka 运维命令 100 条

前言

本文按 Apache Kafka 4.3 的 KRaft 架构整理 100 条命令。Kafka 官方脚本位于发行包 bin/ 目录，示例集群地址为 localhost:9092，客户端配置为 config/client.properties。

删除 Topic、修改分区、副本重分配、Leader 选举和消费者组位点会影响数据或服务，执行前应备份配置并确认目标范围。

一、版本、KRaft 与启动

1. 查看 Broker API 版本

Bash

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

2. 生成集群 ID

Bash

1KAFKA_CLUSTER_ID=$(bin/kafka-storage.sh random-uuid)

3. 格式化 KRaft 存储

Bash

1bin/kafka-storage.sh format -t "$KAFKA_CLUSTER_ID" -c config/server.properties

4. 查看存储格式信息

Bash

1bin/kafka-storage.sh info -c config/server.properties

5. 前台启动 Broker

Bash

1bin/kafka-server-start.sh config/server.properties

6. 后台启动 Broker

Bash

1bin/kafka-server-start.sh -daemon config/server.properties

7. 停止 Broker

Bash

1bin/kafka-server-stop.sh

8. 查看 systemd 状态

Bash

1systemctl status kafka --no-pager

9. 查看 Broker 日志

Bash

1journalctl -u kafka -n 200 --no-pager

10. 查看监听端口

Bash

1ss -lntp '( sport = :9092 )'

二、Topic 管理

11. 列出 Topic

Bash

1bin/kafka-topics.sh --bootstrap-server localhost:9092 --list

12. 创建 Topic

Bash

1bin/kafka-topics.sh --bootstrap-server localhost:9092 --create --topic orders --partitions 6 --replication-factor 3

13. 创建带配置的 Topic

Bash

1bin/kafka-topics.sh --bootstrap-server localhost:9092 --create --topic audit --partitions 6 --replication-factor 3 --config retention.ms=604800000

14. 查看 Topic 详情

Bash

1bin/kafka-topics.sh --bootstrap-server localhost:9092 --describe --topic orders

15. 查看所有 Topic 详情

Bash

1bin/kafka-topics.sh --bootstrap-server localhost:9092 --describe

16. 只看副本不足分区

Bash

1bin/kafka-topics.sh --bootstrap-server localhost:9092 --describe --under-replicated-partitions

17. 查看不可用分区

Bash

1bin/kafka-topics.sh --bootstrap-server localhost:9092 --describe --unavailable-partitions

18. 增加分区

Bash

1bin/kafka-topics.sh --bootstrap-server localhost:9092 --alter --topic orders --partitions 12

19. 按模式列出 Topic

Bash

1bin/kafka-topics.sh --bootstrap-server localhost:9092 --list --topic 'orders.*'

20. 删除 Topic

Bash

1bin/kafka-topics.sh --bootstrap-server localhost:9092 --delete --topic old-orders

三、生产与消费

21. 启动控制台生产者

Bash

1bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic orders

22. 发送带 Key 的消息

Bash

1bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic orders --property parse.key=true --property key.separator=:

23. 从文件发送消息

Bash

1bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic orders < messages.txt

24. 启动控制台消费者

Bash

1bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic orders

25. 从最早消息消费

Bash

1bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic orders --from-beginning

26. 使用消费者组

Bash

1bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic orders --group order-debug

27. 最多读取 10 条

Bash

1bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic orders --from-beginning --max-messages 10

28. 显示 Key

Bash

1bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic orders --property print.key=true --property key.separator=':'

29. 显示时间戳和分区

Bash

1bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic orders --property print.timestamp=true --property print.partition=true

30. 指定分区和位点

Bash

1bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic orders --partition 0 --offset 100 --max-messages 10

四、消费者组

31. 列出消费者组

Bash

1bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list

32. 查看组位点与积压

Bash

1bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group order-service

33. 查看组成员

Bash

1bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group order-service --members

34. 查看组状态

Bash

1bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group order-service --state

35. 删除空闲消费者组

Bash

1bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --delete --group old-group

36. 预览重置到最早位点

Bash

1bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group order-service --topic orders --reset-offsets --to-earliest

37. 执行重置到最早位点

Bash

1bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group order-service --topic orders --reset-offsets --to-earliest --execute

38. 重置到最新位点

Bash

1bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group order-service --topic orders --reset-offsets --to-latest --execute

39. 按时间重置位点

Bash

1bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group order-service --topic orders --reset-offsets --to-datetime 2026-07-27T00:00:00.000 --execute

40. 导出重置方案

Bash

1bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group order-service --topic orders --reset-offsets --shift-by -100 --export

五、配置管理

41. 查看 Topic 配置

Bash

1bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type topics --entity-name orders --describe

42. 修改 Topic 保留时间

Bash

1bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type topics --entity-name orders --alter --add-config retention.ms=259200000

43. 删除 Topic 动态配置

Bash

1bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type topics --entity-name orders --alter --delete-config retention.ms

44. 查看 Broker 配置

Bash

1bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type brokers --entity-name 1 --describe --all

45. 修改 Broker 动态配置

Bash

1bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type brokers --entity-name 1 --alter --add-config log.cleaner.threads=2

46. 查看客户端配额

Bash

1bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type clients --describe

47. 设置客户端生产配额

Bash

1bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type clients --entity-name order-api --alter --add-config producer_byte_rate=10485760

48. 设置用户消费配额

Bash

1bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type users --entity-name appuser --alter --add-config consumer_byte_rate=10485760

49. 查看用户 SCRAM 凭据

Bash

1bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type users --entity-name appuser --describe

50. 创建 SCRAM 凭据

Bash

1bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type users --entity-name appuser --alter --add-config 'SCRAM-SHA-512=[iterations=8192,password=REPLACE_ME]'

六、位点、日志与数据检查

51. 获取最新位点

Bash

1bin/kafka-get-offsets.sh --bootstrap-server localhost:9092 --topic orders --time latest

52. 获取最早位点

Bash

1bin/kafka-get-offsets.sh --bootstrap-server localhost:9092 --topic orders --time earliest

53. 获取指定时间位点

Bash

1bin/kafka-get-offsets.sh --bootstrap-server localhost:9092 --topic orders --time 1785110400000

54. 查看日志段内容

Bash

1bin/kafka-dump-log.sh --files /data/kafka/orders-0/00000000000000000000.log --print-data-log

55. 查看索引文件

Bash

1bin/kafka-dump-log.sh --files /data/kafka/orders-0/00000000000000000000.index

56. 查看生产者快照

Bash

1bin/kafka-dump-log.sh --files /data/kafka/orders-0/00000000000000000000.snapshot

57. 校验日志目录元数据

Bash

1bin/kafka-storage.sh info -c config/server.properties

58. 查看日志目录副本

Bash

1bin/kafka-log-dirs.sh --bootstrap-server localhost:9092 --describe

59. 查看指定 Broker 日志目录

Bash

1bin/kafka-log-dirs.sh --bootstrap-server localhost:9092 --describe --broker-list 1

60. 删除指定偏移前的数据

Bash

1bin/kafka-delete-records.sh --bootstrap-server localhost:9092 --offset-json-file delete-records.json

七、副本重分配与 Leader

61. 生成重分配方案

Bash

1bin/kafka-reassign-partitions.sh --bootstrap-server localhost:9092 --topics-to-move-json-file topics.json --broker-list '1,2,3,4' --generate

62. 执行重分配

Bash

1bin/kafka-reassign-partitions.sh --bootstrap-server localhost:9092 --reassignment-json-file reassignment.json --execute

63. 校验重分配

Bash

1bin/kafka-reassign-partitions.sh --bootstrap-server localhost:9092 --reassignment-json-file reassignment.json --verify

64. 限速执行重分配

Bash

1bin/kafka-reassign-partitions.sh --bootstrap-server localhost:9092 --reassignment-json-file reassignment.json --execute --throttle 50000000

65. 取消重分配

Bash

1bin/kafka-reassign-partitions.sh --bootstrap-server localhost:9092 --reassignment-json-file reassignment.json --cancel

66. 首选副本选主

Bash

1bin/kafka-leader-election.sh --bootstrap-server localhost:9092 --election-type preferred --all-topic-partitions

67. 指定分区首选选主

Bash

1bin/kafka-leader-election.sh --bootstrap-server localhost:9092 --election-type preferred --topic orders --partition 0

68. 非干净选主

Bash

1bin/kafka-leader-election.sh --bootstrap-server localhost:9092 --election-type unclean --topic orders --partition 0

可能造成数据丢失，仅用于明确接受风险的故障恢复。

69. 查看分区副本分布

Bash

1bin/kafka-topics.sh --bootstrap-server localhost:9092 --describe --topic orders

70. 查看副本同步异常

Bash

1bin/kafka-topics.sh --bootstrap-server localhost:9092 --describe --under-min-isr-partitions

八、KRaft 元数据与 ACL

71. 查看 KRaft 仲裁状态

Bash

1bin/kafka-metadata-quorum.sh --bootstrap-controller localhost:9093 describe --status

72. 查看 KRaft 副本状态

Bash

1bin/kafka-metadata-quorum.sh --bootstrap-controller localhost:9093 describe --replication

73. 查看元数据 Shell 帮助

Bash

1bin/kafka-metadata-shell.sh --help

74. 查看元数据快照

Bash

1bin/kafka-dump-log.sh --cluster-metadata-decoder --files /data/kafka/__cluster_metadata-0/00000000000000000000.log

75. 列出 ACL

Bash

1bin/kafka-acls.sh --bootstrap-server localhost:9092 --list

76. 添加 Topic 读权限

Bash

1bin/kafka-acls.sh --bootstrap-server localhost:9092 --add --allow-principal User:appuser --operation Read --topic orders

77. 添加消费者组权限

Bash

1bin/kafka-acls.sh --bootstrap-server localhost:9092 --add --allow-principal User:appuser --operation Read --group order-service

78. 添加生产权限

Bash

1bin/kafka-acls.sh --bootstrap-server localhost:9092 --add --allow-principal User:appuser --producer --topic orders

79. 添加消费权限

Bash

1bin/kafka-acls.sh --bootstrap-server localhost:9092 --add --allow-principal User:appuser --consumer --topic orders --group order-service

80. 删除 ACL

Bash

1bin/kafka-acls.sh --bootstrap-server localhost:9092 --remove --allow-principal User:appuser --operation Read --topic orders

九、性能测试

81. 生产吞吐测试

Bash

1bin/kafka-producer-perf-test.sh --topic perf-test --num-records 1000000 --record-size 1024 --throughput -1 --producer-props bootstrap.servers=localhost:9092

82. 限速生产测试

Bash

1bin/kafka-producer-perf-test.sh --topic perf-test --num-records 100000 --record-size 1024 --throughput 10000 --producer-props bootstrap.servers=localhost:9092 acks=all

83. 消费吞吐测试

Bash

1bin/kafka-consumer-perf-test.sh --bootstrap-server localhost:9092 --topic perf-test --messages 100000

84. 测试事务生产者

Bash

1bin/kafka-transactions.sh --bootstrap-server localhost:9092 list

85. 查看事务状态

Bash

1bin/kafka-transactions.sh --bootstrap-server localhost:9092 describe --transactional-id order-tx

86. 列出共享组

Bash

1bin/kafka-share-groups.sh --bootstrap-server localhost:9092 --list

87. 查看共享组

Bash

1bin/kafka-share-groups.sh --bootstrap-server localhost:9092 --describe --group share-group

88. 查看 JVM 进程

Bash

1jcmd | grep -i kafka

89. 查看 JVM 堆

Bash

1jcmd KAFKA_PID GC.heap_info

90. 查看线程栈

Bash

1jcmd KAFKA_PID Thread.print > kafka-threads.txt

十、Connect 与综合排障

91. 启动独立 Connect

Bash

1bin/connect-standalone.sh config/connect-standalone.properties config/file-source.properties config/file-sink.properties

92. 启动分布式 Connect

Bash

1bin/connect-distributed.sh config/connect-distributed.properties

93. 查看 Connector

Bash

1curl -s http://localhost:8083/connectors | jq

94. 查看 Connector 状态

Bash

1curl -s http://localhost:8083/connectors/my-source/status | jq

95. 暂停 Connector

Bash

1curl -fsS -X PUT http://localhost:8083/connectors/my-source/pause

96. 恢复 Connector

Bash

1curl -fsS -X PUT http://localhost:8083/connectors/my-source/resume

97. 重启失败任务

Bash

1curl -fsS -X POST 'http://localhost:8083/connectors/my-source/restart?includeTasks=true&onlyFailed=true'

98. 查看 JMX 指标端口

Bash

1ss -lntp '( sport = :9999 )'

99. 检查集群关键异常

Bash

1grep -Ei 'UnderReplicated|OfflinePartition|ERROR|FATAL' logs/server.log | tail -100

100. 生成集群诊断摘要

Bash

1{ bin/kafka-broker-api-versions.sh --bootstrap-server localhost:9092; bin/kafka-topics.sh --bootstrap-server localhost:9092 --describe --under-replicated-partitions; bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list; } > kafka-check.txt

总结

Kafka 运维应持续关注 ISR、副本不足、磁盘容量、消费者积压、Controller 仲裁和客户端错误。KRaft 环境不要混用旧 ZooKeeper 参数，所有重分配、位点重置和非干净选主都应先预览并具备回退方案。

Bash

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

Bash

1KAFKA_CLUSTER_ID=$(bin/kafka-storage.sh random-uuid)

Bash

1bin/kafka-storage.sh format -t "$KAFKA_CLUSTER_ID" -c config/server.properties

Bash

1bin/kafka-storage.sh info -c config/server.properties

Bash

1bin/kafka-server-start.sh config/server.properties

Bash

1bin/kafka-server-start.sh -daemon config/server.properties

Bash

1bin/kafka-server-stop.sh

Bash

1systemctl status kafka --no-pager

Bash

1journalctl -u kafka -n 200 --no-pager

Bash

1ss -lntp '( sport = :9092 )'

Bash

1bin/kafka-topics.sh --bootstrap-server localhost:9092 --list

Bash

1bin/kafka-topics.sh --bootstrap-server localhost:9092 --create --topic orders --partitions 6 --replication-factor 3

Bash

1bin/kafka-topics.sh --bootstrap-server localhost:9092 --create --topic audit --partitions 6 --replication-factor 3 --config retention.ms=604800000

Bash

1bin/kafka-topics.sh --bootstrap-server localhost:9092 --describe --topic orders

Bash

1bin/kafka-topics.sh --bootstrap-server localhost:9092 --describe

Bash

1bin/kafka-topics.sh --bootstrap-server localhost:9092 --describe --under-replicated-partitions

Bash

1bin/kafka-topics.sh --bootstrap-server localhost:9092 --describe --unavailable-partitions

Bash

1bin/kafka-topics.sh --bootstrap-server localhost:9092 --alter --topic orders --partitions 12

Bash

1bin/kafka-topics.sh --bootstrap-server localhost:9092 --list --topic 'orders.*'

Bash

1bin/kafka-topics.sh --bootstrap-server localhost:9092 --delete --topic old-orders

Bash

1bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic orders

Bash

1bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic orders --property parse.key=true --property key.separator=:

Bash

1bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic orders < messages.txt

Bash

1bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic orders

Bash

1bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic orders --from-beginning

Bash

1bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic orders --group order-debug

Bash

1bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic orders --from-beginning --max-messages 10

Bash

1bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic orders --property print.key=true --property key.separator=':'

Bash

1bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic orders --property print.timestamp=true --property print.partition=true

Bash

1bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic orders --partition 0 --offset 100 --max-messages 10

Bash

1bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list

Bash

1bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group order-service

Bash

1bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group order-service --members

Bash

1bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group order-service --state

Bash

1bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --delete --group old-group

Bash

1bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group order-service --topic orders --reset-offsets --to-earliest

Bash

1bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group order-service --topic orders --reset-offsets --to-earliest --execute

Bash

1bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group order-service --topic orders --reset-offsets --to-latest --execute

Bash

1bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group order-service --topic orders --reset-offsets --to-datetime 2026-07-27T00:00:00.000 --execute

Bash

1bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group order-service --topic orders --reset-offsets --shift-by -100 --export

Bash

1bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type topics --entity-name orders --describe

Bash

1bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type topics --entity-name orders --alter --add-config retention.ms=259200000

Bash

1bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type topics --entity-name orders --alter --delete-config retention.ms

Bash

1bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type brokers --entity-name 1 --describe --all

Bash

1bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type brokers --entity-name 1 --alter --add-config log.cleaner.threads=2

Bash

1bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type clients --describe

Bash

1bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type clients --entity-name order-api --alter --add-config producer_byte_rate=10485760

Bash

1bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type users --entity-name appuser --alter --add-config consumer_byte_rate=10485760

Bash

1bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type users --entity-name appuser --describe

Bash

1bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type users --entity-name appuser --alter --add-config 'SCRAM-SHA-512=[iterations=8192,password=REPLACE_ME]'

Bash

1bin/kafka-get-offsets.sh --bootstrap-server localhost:9092 --topic orders --time latest

Bash

1bin/kafka-get-offsets.sh --bootstrap-server localhost:9092 --topic orders --time earliest

Bash

1bin/kafka-get-offsets.sh --bootstrap-server localhost:9092 --topic orders --time 1785110400000

Bash

1bin/kafka-dump-log.sh --files /data/kafka/orders-0/00000000000000000000.log --print-data-log

Bash

1bin/kafka-dump-log.sh --files /data/kafka/orders-0/00000000000000000000.index

Bash

1bin/kafka-dump-log.sh --files /data/kafka/orders-0/00000000000000000000.snapshot

Bash

1bin/kafka-storage.sh info -c config/server.properties

Bash

1bin/kafka-log-dirs.sh --bootstrap-server localhost:9092 --describe

Bash

1bin/kafka-log-dirs.sh --bootstrap-server localhost:9092 --describe --broker-list 1

Bash

1bin/kafka-delete-records.sh --bootstrap-server localhost:9092 --offset-json-file delete-records.json

Bash

1bin/kafka-reassign-partitions.sh --bootstrap-server localhost:9092 --topics-to-move-json-file topics.json --broker-list '1,2,3,4' --generate

Bash

1bin/kafka-reassign-partitions.sh --bootstrap-server localhost:9092 --reassignment-json-file reassignment.json --execute

Bash

1bin/kafka-reassign-partitions.sh --bootstrap-server localhost:9092 --reassignment-json-file reassignment.json --verify

Bash

1bin/kafka-reassign-partitions.sh --bootstrap-server localhost:9092 --reassignment-json-file reassignment.json --execute --throttle 50000000

Bash

1bin/kafka-reassign-partitions.sh --bootstrap-server localhost:9092 --reassignment-json-file reassignment.json --cancel

Bash

1bin/kafka-leader-election.sh --bootstrap-server localhost:9092 --election-type preferred --all-topic-partitions

Bash

1bin/kafka-leader-election.sh --bootstrap-server localhost:9092 --election-type preferred --topic orders --partition 0

Bash

1bin/kafka-leader-election.sh --bootstrap-server localhost:9092 --election-type unclean --topic orders --partition 0

Bash

1bin/kafka-topics.sh --bootstrap-server localhost:9092 --describe --topic orders

Bash

1bin/kafka-topics.sh --bootstrap-server localhost:9092 --describe --under-min-isr-partitions

Bash

1bin/kafka-metadata-quorum.sh --bootstrap-controller localhost:9093 describe --status

Bash

1bin/kafka-metadata-quorum.sh --bootstrap-controller localhost:9093 describe --replication

Bash

1bin/kafka-metadata-shell.sh --help

Bash

1bin/kafka-dump-log.sh --cluster-metadata-decoder --files /data/kafka/__cluster_metadata-0/00000000000000000000.log

Bash

1bin/kafka-acls.sh --bootstrap-server localhost:9092 --list

Bash

1bin/kafka-acls.sh --bootstrap-server localhost:9092 --add --allow-principal User:appuser --operation Read --topic orders

Bash

1bin/kafka-acls.sh --bootstrap-server localhost:9092 --add --allow-principal User:appuser --operation Read --group order-service

Bash

1bin/kafka-acls.sh --bootstrap-server localhost:9092 --add --allow-principal User:appuser --producer --topic orders

Bash

1bin/kafka-acls.sh --bootstrap-server localhost:9092 --add --allow-principal User:appuser --consumer --topic orders --group order-service

Bash

1bin/kafka-acls.sh --bootstrap-server localhost:9092 --remove --allow-principal User:appuser --operation Read --topic orders

Bash

1bin/kafka-producer-perf-test.sh --topic perf-test --num-records 1000000 --record-size 1024 --throughput -1 --producer-props bootstrap.servers=localhost:9092

Bash

1bin/kafka-producer-perf-test.sh --topic perf-test --num-records 100000 --record-size 1024 --throughput 10000 --producer-props bootstrap.servers=localhost:9092 acks=all

Bash

1bin/kafka-consumer-perf-test.sh --bootstrap-server localhost:9092 --topic perf-test --messages 100000

Bash

1bin/kafka-transactions.sh --bootstrap-server localhost:9092 list

Bash

1bin/kafka-transactions.sh --bootstrap-server localhost:9092 describe --transactional-id order-tx

Bash

1bin/kafka-share-groups.sh --bootstrap-server localhost:9092 --list

Bash

1bin/kafka-share-groups.sh --bootstrap-server localhost:9092 --describe --group share-group

Bash

1jcmd | grep -i kafka

Bash

1jcmd KAFKA_PID GC.heap_info

Bash

1jcmd KAFKA_PID Thread.print > kafka-threads.txt

Bash

1bin/connect-standalone.sh config/connect-standalone.properties config/file-source.properties config/file-sink.properties

Bash

1bin/connect-distributed.sh config/connect-distributed.properties

Bash

1curl -s http://localhost:8083/connectors | jq

Bash

1curl -s http://localhost:8083/connectors/my-source/status | jq

Bash

1curl -fsS -X PUT http://localhost:8083/connectors/my-source/pause

Bash

1curl -fsS -X PUT http://localhost:8083/connectors/my-source/resume

Bash

1curl -fsS -X POST 'http://localhost:8083/connectors/my-source/restart?includeTasks=true&onlyFailed=true'

Bash

1ss -lntp '( sport = :9999 )'

Bash

1grep -Ei 'UnderReplicated|OfflinePartition|ERROR|FATAL' logs/server.log | tail -100

Bash

1{ bin/kafka-broker-api-versions.sh --bootstrap-server localhost:9092; bin/kafka-topics.sh --bootstrap-server localhost:9092 --describe --under-replicated-partitions; bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list; } > kafka-check.txt