apache / apache/beam

[Feature Request]: Set option for acknowledge the messages in PulsarIO reader

Open
#22,054 3 comments 0 reactions 1 assignee Claimed by @MarcoRob View on GitHub
io java new feature P2 pulsar
Dominant language
Java
Stars
8.7k
Forks
4.7k
Avg merge
1d 20h
Merged PRs (30d)
196

Description

### What would you like to happen?

Currently, the reader for PulsarIO used the Reader interface to manually handle the cursors in the ReadPulsarDoFn and it does not have the option to acknowledge the messages. So I am raising this issue to have this TODO and allow the user to set the acknowledgment of messages and implement and analyze the acknowledgment of the messages may be in batch or each time a bundle inside DoFn is done (this should be to be taken for analysis)

### Issue Priority

Priority: 2

### Issue Component

Component: io-java-pulsar

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.