Allow overriding control topic offset reset config

databricks / iceberg-kafka-connect

Apache License 2.0

219 stars 49 forks source link

Allow overriding control topic offset reset config #90

Closed bryanck closed 1 year ago

bryanck commented 1 year ago

This PR allows the specified kafka config auto.offset.reset to take precedence for the control topic consumer. Also tests were updated to set this to earliest to ensure the data files written are committed in the integration tests.