fix: set max.in.flight.requests.per.connection to 1 (#391)

This preserves order when enable.idempotency is false
googleapis · Jan 23, 2023 · 62800a8 · 62800a8
1 parent ff2664a
commit 62800a8
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pubsublite-kafka-auth/src/main/java/com/google/cloud/pubsublite/kafka/ClientParameters.java b/pubsublite-kafka-auth/src/main/java/com/google/cloud/pubsublite/kafka/ClientParameters.java
@@ -38,6 +38,8 @@ public static Map<String, Object> getProducerParams(
       ProjectIdOrNumber project, CloudRegion region) {
     HashMap<String, Object> params = new HashMap<>();
     params.put("enable.idempotence", false);
+    // While ENABLE_IDEMPOTENCE_CONFIG is false, this must be 1 to preserver ordering.
+    params.put("max.in.flight.requests.per.connection", 1);
     params.put("bootstrap.servers", getEndpoint(region));
     params.put("security.protocol", "SASL_SSL");
     params.put("sasl.mechanism", "OAUTHBEARER");