GitHub user startjava added a comment to the discussion: what time merge about
this version ?
```
package com.ghy.www.cumulativeacknowledgement.consumer.listener;
import org.apache.pulsar.client.api.Consumer;
import org.apache.pulsar.client.api.Message;
import org.apache.pulsar.client.api.MessageListener;
import org.apache.pulsar.client.api.PulsarClientException;
import org.springframework.stereotype.Component;
@Component
public class MyMessageListener1 implements MessageListener {
@Override
public void received(Consumer consumer, Message msg) {
try {
String messageString = new String(msg.getData());
System.out.println(messageString);
if (messageString.equals("acknowledge消息5")) {
consumer.acknowledge(msg);
System.out.println(messageString + "执行了acknowledge");
}
} catch (PulsarClientException e) {
throw new RuntimeException(e);
}
}
}
```
two method both test , both return 0 .
i want implement Cumulative and Not Cumulative Diff 。
i code envirment has error ?
GitHub link:
https://github.com/apache/pulsar/discussions/17978#discussioncomment-3844926
----
This is an automatically sent email for dev@pulsar.apache.org.
To unsubscribe, please send an email to: dev-unsubscr...@pulsar.apache.org
