Matthew Seal

Schema registry code would need to overwrite the `verify` attribute with an [SSLContext](https://docs.python.org/3/library/ssl.html#ssl.SSLContext) object with the cert loaded from content. For the producer side it would need `rd_kafka_conf_set_ssl_cert` to be...

Related PR needs to be evaluated for reuse with modern versions of the codebase and a test case added to validate before merge + linting resolutions

Need to evaluate if this is still a relevant issue or not with modern versions of the library

Thanks for raising the issue @mkmoisen -- I've been a preliminary pass of the C code change requirements. It seems like the code changes will be minimal but testing this...

@cclauss no, there is a wheel compiled for free-threading but the C-bindings aren't aware of this yet. @dpdani if you want to take a pass on updating the C-bindings, we're...

Marked as an improvement (code also mentions the intention to lift this limitation). You can probably workaround this by requesting the list_consumer_group_offsets calls in separate threads to parallelize the network...

I think you have a typo of `fetch.wait.max.ams` instead of `fetch.wait.max.ms` in the exception message which doesn't match the code you posted above. Did you run this with uncommitted code...

Apologies no one responded quickly to this ticket. Are you sure you have the right `sasl.kerberos.service.name` ? Can you post your config you used successfully in Java kafka? Kerberos is...

No the `oauth_cb` function is only called for initial token fetch: > This callback is useful only when ``sasl.mechanisms=OAUTHBEARER`` is set and > is served to get the initial token...

Specifically > You could send some kind of "heartbeat" message to keep the connection and token fresh but it's not necessary at all. The error message is benign to behavior....