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 86bc45286d1 fixed issue in python precommit (#36561)
add 0697e54a543 Kerberos Authentication for KafkaIO (#36099)
No new revisions were added by this update.
Summary of changes:
build.gradle.kts | 1 +
.../{sbe => kafka-factories}/build.gradle | 27 ++-
.../kafka/factories/FileAwareFactoryFn.java | 258 ++++++++++++++++++++
.../kafka/factories/KerberosConsumerFactoryFn.java | 150 ++++++++++++
.../extensions/kafka/factories}/package-info.java | 4 +-
.../kafka/factories/FileAwareFactoryFnTest.java | 268 +++++++++++++++++++++
.../factories/KerberosConsumerFactoryFnTest.java | 242 +++++++++++++++++++
settings.gradle.kts | 1 +
8 files changed, 940 insertions(+), 11 deletions(-)
copy sdks/java/extensions/{sbe => kafka-factories}/build.gradle (53%)
create mode 100644
sdks/java/extensions/kafka-factories/src/main/java/org/apache/beam/sdk/extensions/kafka/factories/FileAwareFactoryFn.java
create mode 100644
sdks/java/extensions/kafka-factories/src/main/java/org/apache/beam/sdk/extensions/kafka/factories/KerberosConsumerFactoryFn.java
copy
{.test-infra/mock-apis/src/main/java/org/apache/beam/testinfra/mockapis/echo/v1
=>
sdks/java/extensions/kafka-factories/src/main/java/org/apache/beam/sdk/extensions/kafka/factories}/package-info.java
(85%)
create mode 100644
sdks/java/extensions/kafka-factories/src/test/java/org/apache/beam/sdk/extensions/kafka/factories/FileAwareFactoryFnTest.java
create mode 100644
sdks/java/extensions/kafka-factories/src/test/java/org/apache/beam/sdk/extensions/kafka/factories/KerberosConsumerFactoryFnTest.java
