Hacktoberfest 2026: the issues maintainers tagged for October, open and beginner-friendly. Browse Hacktoberfest issues

Acknowledge outside of consumeMany and consumeOne

Open
  • Is something wrong?
#220 1 comment 0 reactions 1 assignee View on GitHub

@lhotari is already working on this.

Since May 27, 2025.

Assessment

This issue has not been assessed yet.

Description

Is there support to acknowledge outside of the consumeOne and consumeMany of AdaptedReactiveMessageConsumer?

My usecase is I want to consume the messages but don't want the acknowledgement to happen within the consumeOne, consumeMany. I want to separately acknowledge the pulsar message later on in the reactive pipeline after consumeOne, consumeMany.

e.g.

ReactiveMessageConsumer<String> messageConsumer=
		reactivePulsarClient.messageConsumer(Schema.STRING)
				.topic(topicName)
				.subscriptionName("sub")
				.build();
messageConsumer.consumeMany(messageFlux ->
			messageFlux.map(message ->
			 doSomeProcessing(message)))
		.flatMap(msgResult -> {
			MessageId msgId = msgResult.getMessageId();
			// Acknowledge here outside of consumeMany or consumeOne
			handleAcknowledgement(msgId);
		})
		// for demonstration
		.subscribe(System.out::println);
Dominant language
Java
Stars
67
Forks
23
No merged PRs in 30d

Getting set up

First steps

  1. Read the whole issue, then the project's contributing guide.
  2. Comment on the issue to say you are picking it up — it saves two people doing the same work.
  3. Fork the repository and make your change on a branch.
  4. Open a pull request that references the issue number.

More from apache/pulsar-client-reactive

All issues in apache/pulsar-client-reactive

Similar issues

More Java issues

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.