chiradip opened a new issue, #2205: URL: https://github.com/apache/iggy/issues/2205
**Title:** `[Java SDK] Add comprehensive offset management for consumer groups` **Description:** Current SDK has limited offset management capabilities, making it difficult to implement proper checkpoint recovery in stream processors. **Current State:** - Basic auto-commit flag - No manual offset control - No seek capability **Proposed Solution:** ```java // Manual offset management client.consumers().commitOffset(streamId, topicId, partition, offset); client.consumers().seekToOffset(streamId, topicId, partition, offset); client.consumers().seekToTimestamp(streamId, topicId, timestamp); // Get current positions Map<Integer, Long> positions = client.consumers().currentPositions(streamId, topicId); ``` -- 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]
