apache / apache/iggy

[Java SDK] Add comprehensive offset management for consumer groups

Open
#2,205 1 comment 0 reactions 1 assignee Claimed by @ex172000 View on GitHub
enhancement java
Dominant language
Rust
Stars
4.9k
Forks
432
Avg merge
2d 10h
Merged PRs (30d)
173

Description

**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 positions = client.consumers().currentPositions(streamId, topicId);
```

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.