Not supported KIP-368: Allow SASL Connections to Periodically Re-Authenticate

[ppatierno]

Hi, it seems that Sarama doesn't support KIP-368 which is about re-authenticating when on the broker the connections.max.reauth.ms is set as timeout. Right now Sarama is able to handle the disconnection and reconnecting, even if it works for producer and consumer but not for the admin client as reported by https://github.com/Shopify/sarama/issues/2042. Is there any plan/roadmap to add this feature to future Sarama version?

[dnwe]

@ppatierno this should now be available on main thanks to @k-wall and will be in the next upcoming release version of Sarama

[ppatierno]

@dnwe @k-wall thanks! that's great!

[bodypumper]

@dnwe Hi, when will the new version be released about this issue?

[fikersd]

refresh client controller before attempting to operate kafka ACL. `client, err := sarama.NewClient([]string{"localhost:9092"}, sarama.NewConfig()) if err != nil { panic(err) }

for { if _, err := client.RefreshController(); err != nil { panic(err) } admin, err := sarama.NewClusterAdminFromClient(client) if err != nil { panic(err) } if err := admin.CreateACLs([]*sarama.ResourceAcls{ // TODO: your acl resources }); err != nil { panic(err) } log.Println("create acls ...") time.Sleep(time.Minute * 30) } `

[k-wall]

Hi, @dnwe I think this issue is closeable.