Dominic Evans
Dominic Evans
@825644691 I don't understand the question? Here you've essentially populated a ProducerMessage with a string value containing the json body that you want to publish via Sarama. You've (correctly) used...
@parikdepa the issue is correct, unfortunately Sarama does a local compare of the pre-compression bytes, and it's probably non-trivial to fix at the moment. However, this was always (as far...
Yes for a long time it seems that the `gh-pages` branch hasn't been deploying out to the pages.github.com site correctly. Unfortunately I don't have access to the "settings" tab of...
We use [eapache/go-xerial-snappy](eapache/go-xerial-snappy) which is just a lightweight framing wrapper around [golang/snappy](/golang/snappy). I don't think the latter provides any tuning parameters around its internal buffer usage. We _might_ be able...
@Smriti-OSS ah thanks — yes so the issue is that the consumer has duplicate topics in the consumer group metadata sent as part of the JoinGroupRequest and used for generating...
I've pushed up https://github.com/Shopify/sarama/pull/2285 with the sample unittest and to cover de-duplication in the balance_strategy — as I think it's worth doing it there as well as in the consumer...
When filing an issue please provide logs from Sarama and Kafka if at all possible. You can set sarama.Logger to a log.Logger to capture Sarama debug output From what's in...
@sethpollack thanks for raising this I wasn't aware that AWS had implented their own custom SASL mechanism for this, rather than adopting one of the existing standards. Whilst I can...
hmm, `consumerGroup.Consume` itself shouldn't be panic'ing, it only calls internal Sarama code — do you have an example of a panic you've seen? If the panic is in your own...