Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Records are not acknowledged or the offsets are not updated in single.threaded mode #801

Closed
subkanthi opened this issue Sep 9, 2024 · 0 comments
Assignees
Labels
bug Something isn't working dev-complete Development completed lightweight Issues related to Lightweight version
Milestone

Comments

@subkanthi
Copy link
Collaborator

In addition to markProcessed , the call to markBatchFinished has to added in single.threaded mode.

                if(record.isLastRecordInBatch()) {
                    try {
                        record.getCommitter().markBatchFinished();
                    } catch (InterruptedException e) {
                        throw new RuntimeException(e);
                    }
                }
@subkanthi subkanthi added the lightweight Issues related to Lightweight version label Sep 9, 2024
@subkanthi subkanthi added this to the 2.4.0 milestone Sep 9, 2024
@subkanthi subkanthi self-assigned this Sep 9, 2024
@subkanthi subkanthi added the bug Something isn't working label Sep 9, 2024
@subkanthi subkanthi added the dev-complete Development completed label Sep 12, 2024
@subkanthi subkanthi modified the milestones: 2.4.0, 2.3.1 Sep 18, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
bug Something isn't working dev-complete Development completed lightweight Issues related to Lightweight version
Projects
None yet
Development

No branches or pull requests

1 participant