This is an automated email from the ASF dual-hosted git repository.
johncasey pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from f3e0f6d4962 Updates YAML SDK to replace Kafka read/write transforms
with equivalent managed transforms (#34755)
add cfae8675690 re-introduce the fail fast mechanic with fixes for
documented bugs. (#34659)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 28 ++-
.../KafkaIOReadImplementationCompatibility.java | 1 +
.../beam/sdk/io/kafka/KafkaUnboundedSource.java | 65 ++++++-
.../sdk/io/kafka/WatchForKafkaTopicPartitions.java | 10 +-
.../org/apache/beam/sdk/io/kafka/KafkaIOIT.java | 213 +++++++++++++++++++++
.../sdk/io/kafka/upgrade/KafkaIOTranslation.java | 4 +
.../io/kafka/upgrade/KafkaIOTranslationTest.java | 1 +
7 files changed, 315 insertions(+), 7 deletions(-)
