Dominic Evans

Do your tasks have ordering requirements or are they just isolated units of work? Today, this is likely to be much easier to achieve using a queue provided via a...

@mohilkhare21 I'm not sure that there's much more we can do in Sarama for this. As noted above, when you start a client and ask it to create/join a consumer...

@Chrisss93 thanks for the contribution! A first pass review over the changes and they look good. One initial request, can we cover all the version options from v0, v1, v2,...

@Chrisss93 do you think you might be able to accommodate the above?

These look like AsyncProducer instances that were created but never closed. Are you re-creating producers in your app code?

Can you share what you're supplying as `brokers` value? It seems the bootstrap addresses are malformed in some way. They should be a string slice of hostname:port e.g., ```go brokers...

@ajeyprasad I think the only way you could hit this panic would be if `producer.Close(...)` had been called more than once for the same producer, because it is only the...

Solved?

OK, I was wondering why you closed the GitHub issue then? 😄 Happy to take a look into this. From your output, the error code in the CreateACLs response is...

Looks like this had also previously been rightly reported as an issue with the admin client https://github.com/IBM/sarama/issues/2069