Steve Kamerman

I would also like to be able to get the partition offset details, as there seems to be no other way to compute consumer group lag with this library. I...

I guess I could add an option to disable SNMP - I'm not sure if it's possible to turn it off without the openmanage suite turning it back on.

I agree with @andyli. Unless I'm missing something, as it stands today, the only way to prevent an automated build system using `buildx` from happily building and pushing images for...

Yes, I have seen this condition as well, typically after an attempted reconnection, the status seems to indicate that I am connected, even though no messages are received.

With paho AutoReconnect turned on, I can see it attempting to reconnect while the connection is interrupted: ``` [pinger] ping check 1 [pinger] ping check 3 [pinger] ping check 5...

[CC @tiddnet @mudhoney @paulborile] I've built a self-contained example of the problem: https://github.com/kamermans/emitter-reconnect-issue To reproduce my issue, clone the repo above, then run `docker-compose build` and `docker-compose up`. It will...

Ok, so I have made some progress here. When the client loses a connection, then auto-reconnects, you need to resubscribe to all the channels again. Using the `OnConnect()` handler is...

I've found a discussion about this problem on the eclipse paho MQTT client project: https://github.com/eclipse/paho.mqtt.golang/issues/22 TL;DR: set `CleanSession(false)` and the client will resubscribe you when you reconnect. https://godoc.org/github.com/eclipse/paho.mqtt.golang#ClientOptions.SetCleanSession I'll change...

The issue is still happening, even after using this auto-resubscribe code: ```go func ConnectionLostHandler(client *emitter.Client, reason error) { log.Println("Emitter connection lost, reconnecting. Reason: ", reason.Error()) emitterClient.Disconnect(100 * time.Millisecond) if connErr...

Thanks! I'm also running a couple versions of it on a separate machine that will slack me if it disconnects :). I've been using the master branch from `paho` via...