I'm modifying memsql Kafka Connector code and it seems Kafka connect does not use Kafka consumer subscribe API so I'm wondering if there is any way to change configurations of consumer such as group id, partition assignment strategy,...?
It's possible to override consumer's configuration at the worker level:
consumer.auto.offset.reset=latest
or at the connector level:
"consumer.override.auto.offset.reset": "latest"
2.1m questions
2.1m answers
60 comments
56.6k users