有什么方法可以调整Kafka Connect中的消费者配置吗



我正在修改memsqlKafka连接器代码,Kafka连接似乎没有使用Kafka消费者订阅API,所以我想知道是否有任何方法可以更改消费者的配置,如组id、分区分配策略,。。。?

可以在工人级别覆盖消费者的配置:

consumer.auto.offset.reset=latest

或在连接器级别:

"consumer.override.auto.offset.reset": "latest"

最新更新