Peter Dannemann

Hi @jkratz55, your proposal seems reasonable. I think after the certificate is rotated you'd need to close the Conn opened from the Dialer and then open a new connection. Externalizing...

We should implement [KIP-368](https://issues.apache.org/jira/browse/KAFKA-7352) to solve this. The way other clients appear to handle this ([franz-go example](https://github.com/twmb/franz-go/blob/a1a2a452c33e53c177792b251c523786c4d9fa27/pkg/kgo/broker.go#L373)) is to check the expiration during requests and re authenticate if the expiration...

Hi @salakhovilia could you please provide a minimal reproducible example? Also what do you mean by "incorrect messages"?

With https://github.com/RaRe-Technologies/smart_open/pull/744 this is now supported by passing in a `Retry` object or `ConditionalRetryPolicy` as a blob_open_kwarg with a key of `retry`. You can read more about this [here](https://cloud.google.com/python/docs/reference/storage/latest/google.cloud.storage.blob.Blob#google_cloud_storage_blob_Blob_open). I...

While there may be a goroutine leak I suspect the reason why this is actually problematic for you is because you are creating a new writer each time you are...

Yeah this seems reasonable and was probably a mistake in the initial implementation, can you submit a PR with the change?