kafka怎么配置多個(gè)消費(fèi)者

小億
557
2024-04-10 15:56:38

在Kafka中配置多個(gè)消費(fèi)者可以通過(guò)設(shè)置不同的group.id來(lái)實(shí)現(xiàn)。每個(gè)消費(fèi)者組都可以有多個(gè)消費(fèi)者。以下是配置多個(gè)消費(fèi)者的步驟：

  1. 在配置文件中設(shè)置不同的group.id 在每個(gè)消費(fèi)者的配置文件中設(shè)置不同的group.id，確保每個(gè)消費(fèi)者都屬于不同的消費(fèi)者組。
# Consumer 1
group.id=consumer-group-1

# Consumer 2
group.id=consumer-group-2
  1. 使用不同的消費(fèi)者組來(lái)啟動(dòng)消費(fèi)者 在啟動(dòng)每個(gè)消費(fèi)者時(shí)，使用不同的group.id來(lái)指定不同的消費(fèi)者組。
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --group consumer-group-1

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --group consumer-group-2

通過(guò)以上步驟，您可以配置多個(gè)消費(fèi)者并確保它們屬于不同的消費(fèi)者組，從而實(shí)現(xiàn)多個(gè)消費(fèi)者同時(shí)消費(fèi)同一個(gè)topic的消息。

0 踩