We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f98b69b commit b0f223cCopy full SHA for b0f223c
pulsar-functions/utils/src/test/java/org/apache/pulsar/functions/utils/SinkConfigUtilsTest.java
@@ -95,6 +95,7 @@ public void testConvertBackFidelity() throws IOException {
95
96
sinkConfig.setConfigs(configs);
97
sinkConfig.setRetainOrdering(false);
98
+ sinkConfig.setRetainKeyOrdering(false);
99
sinkConfig.setAutoAck(true);
100
sinkConfig.setTimeoutMs(2000l);
101
sinkConfig.setRuntimeFlags("-DKerberos");
0 commit comments