kafka

kafka copied to clipboard

err: gzip: invalid header

3

https://github.com/optiopay/kafka/blob/1ad0bf381e31017cf3f5858d69f1d2e0ddca2642/broker.go#L1218 the same message can be receive by client in java.

butnet

is it mean that I must to ensure the lb of different partition ？

ShmSeeker

Fetching data with default MaxFetchSize produces an error

1

https://github.com/optiopay/kafka/commit/63a3d15f added a sanity check for response size limiting it to 640 KB. This effectively disallows to use greater values for `(kafka.ConsumerConf).MaxFetchSize` which is set to ~2 MB by default....

andrewslotin

Where is the offset of last message consumed stored. My consumer and producers are different scripts. If my consumer dies, producer will still produce messages. I wouldn't want to consume...

sunilmaiya

optiopay/kafka to use exponential backoff on nodes that are down

1

Background: The KAFKA that I have to write to has 5 nodes, one of which is permanently down. I write to the nodes round robin style. Every 5th write fails...

keep94

Document best practices for high level consumer functionality

1

I ran into #36 and was wondering how others build high [High level consumer](https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example) functionality? Would be great to document/ share some ideas/ code about - building consumer groups -...

alpe