kafka的group组如何指定

kafka

1120

2023/11/14 19:52:57

栏目: 大数据

在Kafka中，可以通过设置消费者的group.id属性来指定消费者属于哪一个消费者组。

在Java客户端中，可以通过以下方式进行设置：

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("group.id", "my-group");

在命令行中，可以使用--group参数来指定消费者组：

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my-topic --group my-group

在Scala客户端中，可以使用consumerGroup参数来指定消费者组：

val consumerSettings = ConsumerSettings(system, new ByteArrayDeserializer, new StringDeserializer)
  .withBootstrapServers("localhost:9092")
  .withGroupId("my-group")

辰迅云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>

kafka的group组如何指定

最新知识库

相关标签