Expose claim attempt maxRetries as Config.PartitionClaimRetries

wvanbergen / kafka

Load-balancing, resuming Kafka consumer for go, backed by Zookeeper.

MIT License

373 stars 141 forks source link

Expose claim attempt maxRetries as Config.PartitionClaimRetries #88

Closed guildencrantz closed 5 days ago

guildencrantz commented 8 years ago

We were getting failures here because it simply wasn't waiting long enough for the old consumer to release the partition. This now allows users to specify how many retries to make, but defaults to the same value (3).