0

我想知道是否可以编辑我稍后在构建 Kafka 消费者时给出的值,即:

public Consumer<String, String> createCons(){
  final Properties props = new Properties();
  props.put(ConsumerConfig.GROUP_ID_CONFIG, "myId")
  props.put...
  Consumer cons = new KafkaConsumer(props)
  return cons
}

生成后是否可以编辑我的消费者 cons 的值(特别是 groupId)?我想测试 groupId 的变化

前任:

cons.setGroupId("newId")

我查看了文档,但那里没有答案。我认为这可能与 Properties 类的行为方式有关,并且实际上无法编辑..

谢谢!

4

1 回答 1

2

消费者实例创建后无法更改其配置。

如果您需要不同的配置,则需要创建客户端的新实例。

于 2020-12-16T13:04:32.867 回答