Kafka命令行生产者发送消息和消费者消费消息实战

已存在的kafka不能重复创建。

broker设置的是1，factor大于broker了，所以报错。

生产者发送消息：

kafka列表出现了新的kafka。

我们使用这个kafka。

我们启动消费者：

我们现在不从头开始创建消费者：

它只会收到我们新发送的消息。

我们再重头开始连，还是会收到之前发的消息。

可以去删除一些topic：

查看broker节点topic状态信息：

 Kafka点对点模型和发布订阅模型讲解

Kafka消费者组配置实现点对点消费模型

进入我们的config目录

编辑一下消费者的配置：

我们主要的就是我们的端口地址和组名。

创建topic：

可以在日志里看到我们的topic：

指定配置文件启动 两个消费者：

我们再启动我们的生产者：

我们模拟多节点，再启动一个节点：

我们发现不会一个消息两个消费者都同时能消费到的，是类似轮训的方式。

只有一个消费者可以消费到数据，一个分区只能被同个消费者组下的某个消费者进行消费

Kafka消费者组配置实现发布订阅消费模型

我们接下来去修改配置文件：

• 创建topic, 2个分区

我们现在去创建生产者：

指定文件选择两个消费者：

 Kafka数据存储流程、原理、LEO+HW讲解