kafka中 --from-beginning的意思
时间: 2024-03-04 10:51:57 浏览: 34
在使用 Kafka 消费者消费消息时,--from-beginning 表示从最早的消息开始消费,而不是从当前消费者加入 topic 后的最新消息开始消费。这个参数通常在需要重新消费之前的消息时使用,比如说你的消费者宕机了一段时间,重新启动后需要消费之前未消费的消息,这时就可以加上 --from-beginning 参数。
相关问题
进入目录/simple/kafka_2.10-0.8.1.1,执行命令bin/kafka-topics.sh --create --zookeeper simple:2181 --replication-factor 1 --partitions 1 --topic logtopic ,bin/kafka-console-producer.sh --broker-list simple:9092 --topic logtopic ,bin/kafka-console-consumer.sh --zookeeper simple:2181 --from-beginning --topic logtopic 是什么意思
这是一组关于Kafka消息队列的命令:
1. `bin/kafka-topics.sh --create --zookeeper simple:2181 --replication-factor 1 --partitions 1 --topic logtopic`:创建一个名为`logtopic`的主题(topic),指定它只有一个分区(partition),副本系数(replication factor)为1,使用zookeeper作为管理和协调的中心,简单来说就是创建了一个可以用来存储消息的主题。
2. `bin/kafka-console-producer.sh --broker-list simple:9092 --topic logtopic`:启动一个控制台生产者(console producer)程序,用于向名为`logtopic`的主题发送消息。`--broker-list`参数指定了Kafka broker的地址,这里是`simple:9092`,即Kafka broker的主机名为`simple`,端口号为`9092`。
3. `bin/kafka-console-consumer.sh --zookeeper simple:2181 --from-beginning --topic logtopic`:启动一个控制台消费者(console consumer)程序,用于从名为`logtopic`的主题消费消息。`--zookeeper`参数指定了zookeeper的地址,这里是`simple:2181`,即zookeeper的主机名为`simple`,端口号为`2181`。`--from-beginning`参数表示从主题的开头开始消费消息。简单来说就是创建了一个可以从主题中读取消息的消费者。
第一关kafka-初体验
以下是kafka的初体验步骤:
1. 下载并解压kafka
```shell
wget https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.8.0/kafka_2.13-2.8.0.tgz
tar -xzf kafka_2.13-2.8.0.tgz
cd kafka_2.13-2.8.0
```
2. 启动kafka服务
```shell
# 启动zookeeper服务
bin/zookeeper-server-start.sh config/zookeeper.properties &
# 启动kafka服务
bin/kafka-server-start.sh config/server.properties &
```
3. 创建一个主题
```shell
bin/kafka-topics.sh --create --topic test --bootstrap-server localhost:9092
```
4. 发送一些消息
```shell
bin/kafka-console-producer.sh --topic test --bootstrap-server localhost:9092
>Hello, Kafka!
>This is my first message.
```
5. 从主题中消费消息
```shell
bin/kafka-console-consumer.sh --topic test --from-beginning --bootstrap-server localhost:9092
Hello, Kafka!
This is my first message.
```