You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by cb...@apache.org on 2022/10/26 12:38:16 UTC
[pulsar-client-reactive] branch main updated: Configure SingletonPulsarContainer with acknowledgmentAtBatchIndexLevelEnabled=true (#13)
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 <lh...@users.noreply.github.com>
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();