This is an automated email from the ASF dual-hosted git repository.
chamikara pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from bb340c2f66a further increase timeout (#36329)
add 4d87e040ac2 Add deterministic redistribute sharding for KafkaIO read.
(#36112)
No new revisions were added by this update.
Summary of changes:
.../apache/beam/sdk/transforms/Redistribute.java | 2 +-
.../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 53 ++++-
.../KafkaIOReadImplementationCompatibility.java | 6 +
.../beam/sdk/io/kafka/KafkaReadRedistribute.java | 124 +++++++++++
...KafkaIOReadImplementationCompatibilityTest.java | 6 +-
.../org/apache/beam/sdk/io/kafka/KafkaIOTest.java | 87 ++++++--
.../sdk/io/kafka/KafkaReadRedistributeTest.java | 231 +++++++++++++++++++++
.../sdk/io/kafka/upgrade/KafkaIOTranslation.java | 10 +
.../io/kafka/upgrade/KafkaIOTranslationTest.java | 1 +
9 files changed, 492 insertions(+), 28 deletions(-)
create mode 100644
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaReadRedistribute.java
create mode 100644
sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaReadRedistributeTest.java
