databricks / iceberg-kafka-connect

Apache License 2.0
213 stars 47 forks source link

remove ListConsumerGroupOffsetsOptions for backward compatibility on older connect versions #277

Open Sharu95 opened 3 months ago

Sharu95 commented 3 months ago

This is a partial fix to #273.

The connector uses transactional producers and I think this call is not needed, as stable offsets are available after producer commit. It is also breaking on earlier versions of connect.

I'm not certain if this is the proper fix, but appreciate if any maintaners of the repo/connector would take a look, so opening a PR to put things into motion 👍🏾 😄

Sharu95 commented 2 months ago

273 is resolved by the reporter, but this PR still stands, at least for backward compatibilty cases