ethanlin01x opened a new pull request, #3877: URL: https://github.com/apache/iggy/pull/3877
## Which issue does this PR address? Closes #3876 ## Rationale The caller could not choose a consumer, so independent Python consumers collided on one server-side offset slot. ## What changed? `poll_messages` built `Consumer::default()` internally, which resolves to numeric id 0, so every Python process polling the same topic/partition shared one offset slot and consumer groups were unreachable. It now takes a required `Consumer` (`Consumer.Single(id)` / `Consumer.Group(id)`), and `partition_id` becomes optional so a group poll can resolve the member's assignment. Breaking change: omitting `consumer` raises `TypeError`. ## Local Execution - Passed - Pre-commit hooks ran ## AI Usage 1. Which tools? Claude code 2. Scope of usage? Analysis and implementation 3. How did you verify the generated code works correctly? Local run 4. Can you explain every line of the code if asked? Yes. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
