GH-265: Ensure assignTimeout is used when no partitions are assigned

spring-attic / spring-integration-kafka

Apache License 2.0

325 stars 179 forks source link

Closed Walliee closed 5 years ago

Walliee commented 5 years ago

Refactored to rely on assignedPartitions for determining whether to use pollTimeout or assignTimeout
Removed redundant assigned flag

fixes #265

garyrussell commented 5 years ago

@Walliee Thanks for the contribution!

In future, please limit commit headlines to 50 chars max; thanks.

Cherry-picked to 3.1.x as 4ec64590f60e814fd80ec2eb16e570a32ea981be