Description
Implement max.block.ms as described in KIP-266: https://cwiki.apache.org/confluence/display/KAFKA/KIP-266%3A+Fix+consumer+indefinite+blocking+behavior.
Attachments
Attachments
Issue Links
- links to
Implement max.block.ms as described in KIP-266: https://cwiki.apache.org/confluence/display/KAFKA/KIP-266%3A+Fix+consumer+indefinite+blocking+behavior.