我想知道是否可以编辑我稍后在构建 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 类的行为方式有关,并且实际上无法编辑..
谢谢!