You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by pa...@apache.org on 2022/06/29 18:17:41 UTC

[beam] branch master updated (fd5e2f4f01a -> 0b6acc7bebc)

This is an automated email from the ASF dual-hosted git repository.

pabloem pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


    from fd5e2f4f01a [BEAM-14347] Update docs to prefer generic registration functions (#17799)
     add 0b6acc7bebc Merge pull request #21752 from Feature/beam 13852 reimplement with dynamic read

No new revisions were added by this update.

Summary of changes:
 sdks/java/io/kafka/build.gradle                    |  12 +-
 .../java/org/apache/beam/sdk/io/kafka/KafkaIO.java |  49 +--
 .../sdk/io/kafka/WatchForKafkaTopicPartitions.java | 185 +++++++++
 .../sdk/io/kafka/WatchKafkaTopicPartitionDoFn.java | 189 ---------
 .../org/apache/beam/sdk/io/kafka/KafkaIOIT.java    | 172 ++++++--
 .../org/apache/beam/sdk/io/kafka/KafkaMocks.java   |  28 ++
 .../io/kafka/WatchForKafkaTopicPartitionsTest.java | 187 +++++++++
 .../io/kafka/WatchKafkaTopicPartitionDoFnTest.java | 449 ---------------------
 8 files changed, 572 insertions(+), 699 deletions(-)
 create mode 100644 sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/WatchForKafkaTopicPartitions.java
 delete mode 100644 sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/WatchKafkaTopicPartitionDoFn.java
 create mode 100644 sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/WatchForKafkaTopicPartitionsTest.java
 delete mode 100644 sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/WatchKafkaTopicPartitionDoFnTest.java