search

dashbitco / broadway_kafka

A Broadway connector for Kafka
222 stars 52 forks source link

Support :query_api_versions brod option #106

Closed rewritten closed 2 years ago

rewritten commented 2 years ago

Hi. With some kafka setups, brod fails to request the api versions because apparently the connection is not upgraded to TLS.

Creating a raw brod client with

[
  query_api_versions: false,
  ssl: [...]
]

does not raise any error, but that option is not supported by BroadwayKafka.BrodClient.

Would you consider adding it? Meanwhile I will copy over the module and whitelist the option locally.

josevalim commented 2 years ago

A PR is welcome!