Getting {:error, {:connect_leader, :timeout}} on subscribe call

[yastanotheruser]

Despite including the connect_timeout option, I'm still getting a timeout when calling brod:subscribe/5. This is because no timeout is passed to the kpro:connect_partition_leader function. Is this a bug? Or am I missing an option?

Mix.install([
  {:brod, "~> 4.3"},
  {:brod_gssapi, "~> 0.1"}
])

Application.ensure_all_started(:brod)

endpoints = [
  {~c"broker1", 9094},
  {~c"broker2", 9094},
  {~c"broker3", 9094}
]

config = [
  ssl: [
    cacertfile: ~c"ca.pem",
    verify: :verify_peer,
    versions: [:"tlsv1.3"]
  ],
  sasl:
    {:callback, :brod_gssapi, {:gssapi, ~c"user.keytab", ~c"[email protected]"}},
  connect_timeout: 60_000
]

:ok = :brod.start_client(endpoints, :kafka_client, config)
topic =  "mytopic"
:ok = :brod.start_consumer(:kafka_client, topic, [])
{:ok, _} = :brod.subscribe(:kafka_client, self(), topic, 0, [])

[zmstone]

Hi @yastanotheruser
Thank you for reporting it.
It's a bug.

[zmstone]

kafka4beam/kafka_protocol#127

[yastanotheruser]

Thank you!