2024年5月3日发(作者:)

kafka 常见命令

Kafka是一种分布式流处理平台,可用于构建实时数据流应用程序。

它是由Apache软件基金会开发的开源项目。Kafka的主要特点是高

吞吐量、低延迟和可扩展性。在使用Kafka时,需要掌握一些常见的

命令,本文将详细介绍这些命令。

一、Kafka基础概念

在学习Kafka命令之前,需要了解一些基础概念:

1. Broker:Kafka集群中的每个服务器节点都被称为Broker。

2. Topic:消息发布者发布消息到Topic中,每个Topic可以有多个

Partition。

3. Partition:每个Topic可以被划分为多个Partition,每个

Partition都有自己的Offset序列。

4. Offset:Offset是一个唯一标识符,表示一个消息在Partition中的

位置。

5. Producer:生产者,用于将消息发布到Topic中。

6. Consumer:消费者,从Topic中读取消息。

7. Consumer Group:消费者组是由多个消费者组成的逻辑概念,它

们共同读取一个或多个Topic中的消息,并且每条消息只能被同一个

Consumer Group 中的一个消费者读取。

二、常见命令

1. 创建Topic

创建一个名为test_topic的Topic,并设置其拥有3个Partition和2

个副本:

```

bin/ --create --zookeeper localhost:2181 --

replication-factor 2 --partitions 3 --topic test_topic

```

2. 查看Topic列表

查看当前Kafka集群中的所有Topic: