Kafka中常用的命令_kafka生产消息命令

以下是Kafka中常用的命令：

启动Kafka服务器：

bin/kafka-server-start.sh config/server.properties
这会启动Kafka服务器并加载指定的配置文件。
1
2
3
4

创建Kafka主题：

bin/kafka-topics.sh --create --topic myTopic --zookeeper localhost:2181 --partitions 3 --replication-factor 1
这将在Kafka中创建一个名为myTopic的主题，并将其分成3个分区，每个分区的副本数为1。
1
2
3
4

查看Kafka主题列表：

bin/kafka-topics.sh --list --zookeeper localhost:2181
这会显示Kafka中所有可用的主题列表。
1
2
3
4

启动Kafka消费者：

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic myTopic --from-beginning
这将启动Kafka的控制台消费者，并从Kafka的名为myTopic的主题的开头开始消费消息。
1
2
3
4

启动Kafka生产者：

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic myTopic
这将启动Kafka的控制台生产者，并将消息发送到Kafka的名为myTopic的主题中。
1
2
3
4

查看Kafka消费者组的偏移量：

bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group myGroup --describe
这将显示名为myGroup的消费者组的偏移量详细信息，包括消费者组内每个消费者的偏移量和分区信息。
1
2
3
4

以上是Kafka中一些常用的命令，还有其他的命令和参数可以用于管理和监控Kafka集群。

创建主题：

bin/kafka-topics.sh --create --topic example-topic --partitions 3 --replication-factor 1 --zookeeper localhost:2181
该命令将创建一个名为example-topic的主题，分为3个分区，每个分区的副本数为1。
1
2
3
4

查看主题列表：

bin/kafka-topics.sh --list --zookeeper localhost:2181
该命令将显示Kafka中所有可用的主题列表。
1
2
3
4

生产消息：

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic example-topic
> This is a test message
> This is another test message
该命令将启动一个命令行控制台生产者，并将消息发送到名为example-topic的主题中。
1
2
3
4
5
6

消费消息：

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic example-topic --from-beginning
该命令将启动一个命令行控制台消费者，并从名为example-topic的主题的开头开始消费消息。
1
2
3
4

消费者组：

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic example-topic --group group-1
该命令将启动一个命令行控制台消费者，并将其添加到名为group-1的消费者组中。同一个消费者组中的消费者将共享消息的消费。
1
2
3
4

查看消费者组：

bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group group-1 --describe
该命令将显示名为group-1的消费者组的偏移量详细信息，包括消费者组内每个消费者的偏移量和分区信息。
1
2
3
4

查看主题分区信息：

bin/kafka-topics.sh --describe --topic example-topic --zookeeper localhost:2181
该命令将显示名为example-topic的主题的分区信息，包括分区ID，副本分配和ISR（已同步副本）。
1
2
3
4

删除主题：

bin/kafka-topics.sh --delete --topic example-topic --zookeeper localhost:2181
该命令将删除名为example-topic的主题。
1
2
3
4

注意：以上命令的参数和选项可能会因版本或环境而有所不同。在使用命令之前，最好查看文档或使用–help选项来获取更多信息。