This is an automated email from the ASF dual-hosted git repository.
cbornet pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git
The following commit(s) were added to refs/heads/main by this push:
new 8e09480 Configure SingletonPulsarContainer with
acknowledgmentAtBatchIndexLevelEnabled=true (#13)
8e09480 is described below
commit 8e0948080dc9a8a7d84964bf2b3b7030994d8fa0
Author: Lari Hotari <[email protected]>
AuthorDate: Wed Oct 26 15:38:11 2022 +0300
Configure SingletonPulsarContainer with
acknowledgmentAtBatchIndexLevelEnabled=true (#13)
- See https://pulsar.apache.org/docs/concepts-messaging/#batching
- By default, batch index acknowledgement is disabled
- For Pulsar standalone, Environment variable must be prefixed with
PULSAR_PREFIX_
since the configuration key acknowledgmentAtBatchIndexLevelEnabled is
missing from
default conf/standalone.conf
---
.../pulsar/reactive/client/adapter/SingletonPulsarContainer.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/SingletonPulsarContainer.java
b/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/SingletonPulsarContainer.java
index a2b8039..e54860c 100644
---
a/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/SingletonPulsarContainer.java
+++
b/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/SingletonPulsarContainer.java
@@ -29,7 +29,8 @@ public final class SingletonPulsarContainer {
/** The singleton instance for Pulsar container. */
public static PulsarContainer PULSAR_CONTAINER = new PulsarContainer(
-
DockerImageName.parse("apachepulsar/pulsar").withTag("2.10.1"));
+
DockerImageName.parse("apachepulsar/pulsar").withTag("2.10.1"))
+
.withEnv("PULSAR_PREFIX_acknowledgmentAtBatchIndexLevelEnabled", "true");
static {
PULSAR_CONTAINER.start();
