我正在修改memsqlKafka连接器代码,Kafka连接似乎没有使用Kafka消费者订阅API,所以我想知道是否有任何方法可以更改消费者的配置,如组id、分区分配策略,。。。?
可以在工人级别覆盖消费者的配置:
consumer.auto.offset.reset=latest
或在连接器级别:
"consumer.override.auto.offset.reset": "latest"