本文为您介绍火山引擎 LAS Kafka 组件相关的一些常用命令。

使用前提 #

已创建实时计算场景下，Kafka 相关的 LAS 集群类型。详见创建集群。

登录集群 #

1. 登录 LAS 控制台
2. 单击集群列表 > 集群名称 > 服务列表 > Kafka > 部署拓扑页签，进入 Kafka 组件服务的部署拓扑。
3. 使用 SSH 登录集群，并输入集群相关认证信息，登录到 Kafka 集群的命令行环境中，来执行相关命令行操作。

常用命令 #

创建 topic #

${KAFKA_HOME}/bin/kafka-topics.sh --create --bootstrap-server `hostname -i`:9092 --topic test --replication-factor 3 --partitions 12

查看 topic 列表 #

${KAFKA_HOME}/bin/kafka-topics.sh --list --bootstrap-server `hostname -i`:9092

查看 topic 状态 #

${KAFKA_HOME}/bin/kafka-topics.sh --describe --bootstrap-server `hostname -i`:9092 --topic test

发送消息 #

${KAFKA_HOME}/bin/kafka-console-producer.sh --broker-list `hostname -i`:9092 --topic test
1
2
3

消费消息 #

${KAFKA_HOME}/bin/kafka-console-consumer.sh --bootstrap-server `hostname -i`:9092 --group testGroup --topic test --from-beginning earliest

查看消费列表 #

${KAFKA_HOME}/bin/kafka-consumer-groups.sh --list --bootstrap-server `hostname -i`:9092

查看消费状态 #

${KAFKA_HOME}/bin/kafka-consumer-groups.sh --bootstrap-server `hostname -i`:9092 --group testGroup --describe