kafka icon indicating copy to clipboard operation
kafka copied to clipboard

KAFKA-6581: Fix the ConsumerGroupCommand indefinite execution if one of the partition is unavailable.

Open SahilAggarwal opened this issue 7 years ago • 2 comments

  • Checks if partition available before calling consumer.position
  • Adds timeout on consumer.position() call.

Committer Checklist (excluded from commit message)

  • [ ] Verify design and implementation
  • [ ] Verify test coverage and CI build status
  • [ ] Verify documentation (including upgrade notes)

SahilAggarwal avatar Feb 22 '18 11:02 SahilAggarwal