Your configuration parameters for a Source connector and Connect worker are:offset.

Each of these settings plays a key role inKafka Connect offset management:

offset.flush.interval.ms=60000 → Offset commits happen every 60 seconds.

offset.flush.timeout.ms=500 → The flush operation times out if it takes more than 500 ms.

offset.storage.topic=connect-offsets → This is the internal topic for storing source offsets.

offset.storage.replication.factor=-1 → This uses thebroker's default replication factor(commonly set via default.replication.factor).

FromKafka Connect Docs:

“If offset.storage.replication.factor=-1, the value will be determined by the broker's default replication factor.”