Dexter Rautenbach

This appears to be a permissions error. Using smbClient (version 4.6.5) on solaris i can see contents in the SHARE drive that gets mounts. However, using go-smb2 or my macbook,...

> Hi! Thanks for the detailed report! > > Would you be able to also try https://github.com/rhansen2/kafka-go/tree/consumer-group-client to see if it reproduced with as well? > > It's still a...

Ive added the following to the bottom of my go.mod file: `replace github.com/segmentio/kafka-go v0.4.27 => github.com/rhansen2/kafka-go consumer-group-client` When running a `go mod vendor` it changed it to: `replace github.com/segmentio/kafka-go v0.4.27...

@rhansen2 , I have tested with the above changes, and still appears to do the same thing. I restarted all the kafka node that is the leader for my topic...

@rhansen2 , I would be happy to give any logs. Is there something specific, because i dont get any verbose logs at all. Literally just the logs that were posted...

Hi @rhansen2 My apologies for the delay, i someone missed this. I will try and get some additional logs for you and send them through.

Hi @rhansen2 , Thanks for the info on the reader logger. As requested, here you go: ``` entering loop for consumer group, "CONSUMER_GROUP_ID" joined group "CONSUMER_GROUP_ID" as member main@localhostname (github.com/segmentio/kafka-go)-c22e4a10-d1b9-4254-b3fe-5090a0ffb323...

@rhansen2 , It is a single CONSUMER_GROUP_ID and TOPIC_NAME. The topic is however split between 5 partitions on kafka.

@rhansen2 , I removed the creation of a new reader in the ReadMessage function, so it now looks like so: ``` func (kr *KafkaReader) ReadMessage(ctx context.Context) ([]byte, error) { if...

I think it's safe to close this off. The logs get very unhappy during the instability, but other than that (Which is kinda expected) it is working as expected. Thanks...