Use XXH3 when hashing values for MantisGroups (#718)

Netflix · Oct 4, 2024 · d01dbd5 · d01dbd5
1 parent c29dfa4
commit d01dbd5
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...s-runtime/src/main/java/io/mantisrx/runtime/executor/WorkerPublisherRemoteObservable.java b/...s-runtime/src/main/java/io/mantisrx/runtime/executor/WorkerPublisherRemoteObservable.java
@@ -146,12 +146,12 @@ private <K> LegacyTcpPushServer<KeyValuePair<K, T>> startKeyValueStage(KeyValueS
         if (stage instanceof ScalarToGroup || stage instanceof GroupToGroup) {
             return PushServers.infiniteStreamLegacyTcpNestedMantisGroup(
                 config, (Observable) toServe, expiryTimeInSecs, keyEncoder,
-                HashFunctions.ketama());
+                HashFunctions.xxh3());
         }
         // ScalarToKey or KeyTKey
         return PushServers.infiniteStreamLegacyTcpNestedGroupedObservable(
             config, (Observable) toServe, expiryTimeInSecs, keyEncoder,
-            HashFunctions.ketama());
+            HashFunctions.xxh3());
     }
 
     private boolean useSpsc() {