Kafka中常用的命令

忘是亡心i 2024-03-25 10:01 112阅读 0赞

以下是Kafka中常用的命令：

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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