search

wvanbergen / kafka

Load-balancing, resuming Kafka consumer for go, backed by Zookeeper.
MIT License
373 stars 141 forks source link

does this client support batch consume? #89

Closed cch123 closed 7 years ago

wvanbergen commented 8 years ago

What do you mean by batches? The API will give you one message at the time, but internally it consumes batches for increased performance.

On Tuesday, 1 March 2016, 曹春晖 notifications@github.com wrote:

— Reply to this email directly or view it on GitHub https://github.com/wvanbergen/kafka/issues/89.

cch123 commented 8 years ago

Then can I control the inner batches size? I haven't found a option to configure.

wvanbergen commented 8 years ago

Yes. The config struct includes the Sarama config struct, which includes several variables to control the batching process. Look it up in the Sarama docs.

On Wednesday, 2 March 2016, 曹春晖 notifications@github.com wrote:

Then can I control the inner batches size? I haven't found a option to configure.

— Reply to this email directly or view it on GitHub https://github.com/wvanbergen/kafka/issues/89#issuecomment-191068405.

cch123 commented 8 years ago

thx!