当前位置：主页 > 经验教程 > 建站编程 >

kafka基础知识详解

kafka基础知识详解深度解析Kafka的基础知识(2)

时间：2023-12-16 10:59:39 来源：IT袋作者：马勇

导读：kafka基础知识详解，如果看到有对应的 broker.id，如上图的 1,2,3 ，就说明已经启动成功了！如果有启动报错，一般是 server.properties 配置文件有误：比如，broker Id 不唯一，IP 端

kafka基础知识详解

如果看到有对应的 broker.id，如上图的 1,2,3，就说明已经启动成功了！

如果有启动报错，一般是 server.properties 配置文件有误：比如，broker Id 不唯一，IP 端口不正确导致。

4. Kafka常见概念与核心组件

以下是 Kafka 中的一些核心组件：

kafka基础知识详解

名称	解释
Broker	Kafka 集群中的消息处理节点，⼀个 Kafka 节点就是⼀个 broker，broker.id 不能重复
Producer	消息生产者，向 broker 发送消息的客户端
Consumer	消费者，从 broker 读取消息的客户端
Topic	主题，Kafka 根据 topic 对消息进⾏归类
Partition	分区，将一个 topic 的消息存放到不同分区
Replication	副本，分区的多个备份，备份分别存放在集群不同的 broker 中

1）主题Topic

什么是Topic

Topic 在 kafka 中是一个逻辑概念，kafka 通过 topic 将消息进行分类，消费者需通过 topic 来进行消费消息。

kafka基础知识详解

注意：发送到 Kafka 集群的每条消息都需要指定⼀个 topic，否则无法进行消费。

如何创建Topic

我们可以通过以下命令创建一个名为 hello-world 的 topic，在创建 topic 时可以指定分区数量和副本数量。

# 创建 topic
./kafka-topics.sh --create --zookeeper 172.16.30.34:2181 --replication-factor 1 --partitions 1 --topic hello-world
# 通过命令查看 zk 节点下所有的主题
./kafka-topics.sh --list --zookeeper 172.16.30.34:2181

以下是在 docker 容器里创建 topic 的例子：