Skip to content

Commit 31acbde

Browse files
Update OrderingMode.java
1 parent d45cd56 commit 31acbde

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

src/main/java/com/google/pubsublite/kafka/sink/OrderingMode.java

+2
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,8 @@
1616
package com.google.pubsublite.kafka.sink;
1717

1818
public enum OrderingMode {
19+
/* Order based on the standard Pub/Sub Lite logic. */
1920
DEFAULT,
21+
/* Send messages to the same partition index they were from in Kafka. */
2022
KAFKA
2123
}

0 commit comments

Comments
 (0)