mailgun / kafka-pixy

gRPC/REST proxy for Kafka
Apache License 2.0
768 stars 119 forks source link

Do not rebalance with unack messages #114

Closed horkhe closed 7 years ago

horkhe commented 7 years ago

Ack timeout can now be greater then subscription timeout. So in absence of incoming consume requests for a topic, rebalancing may be delayed until ack timeout expires for all offered messages. If a new request comes while waiting for ack timeout to expire, then the subscription timer is reset for the topic.