Package org.apache.beam.sdk.extensions.kafka.factories

package org.apache.beam.sdk.extensions.kafka.factories

ConsumerFactoryFns for file paths that exist in GCS or Google SecretManager.

Classes

Class	Description
FileAwareFactoryFn<T>	An abstract SerializableFunction that serves as a base class for factories that need to process a configuration map to handle external resources like files and secrets.
KerberosConsumerFactoryFn