Skip to content

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

@MarcoRob

Description

@MarcoRob

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

Metadata

Metadata

Assignees

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions