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

Class KerberosConsumerFactoryFn

java.lang.Object

org.apache.beam.sdk.extensions.kafka.factories.FileAwareFactoryFn<Consumer<byte[],byte[]>>

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

All Implemented Interfaces:

Serializable, ProcessFunction<Map<String,Object>,Consumer<byte[],byte[]>>, SerializableFunction<Map<String,Object>,Consumer<byte[],byte[]>>

public class KerberosConsumerFactoryFn
extends FileAwareFactoryFn<Consumer<byte[],byte[]>>

See Also:

• Serialized Form

Field Summary

Fields inherited from class org.apache.beam.sdk.extensions.kafka.factories.FileAwareFactoryFn

DIRECTORY_PREFIX, SECRET_VALUE_PREFIX

Constructor Summary

Constructors

Constructor	Description
KerberosConsumerFactoryFn(String krb5ConfigPath)

Method Summary

Modifier and Type	Method	Description
protected Consumer<byte[],byte[]>	createObject(Map<String,Object> config)
protected void	downloadAndProcessExtraFiles()
protected String	processSecret(String originalValue, String secretId, byte[] secretValue)

Methods inherited from class org.apache.beam.sdk.extensions.kafka.factories.FileAwareFactoryFn

apply, downloadExternalFile, getBaseDirectory, getSecret, getSecretWithCache

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

KerberosConsumerFactoryFn

public KerberosConsumerFactoryFn(String krb5ConfigPath)

Method Details

createObject

protected Consumer<byte[],byte[]> createObject(Map<String,Object> config)

Specified by:

createObject in class FileAwareFactoryFn<Consumer<byte[],byte[]>>

downloadAndProcessExtraFiles

protected void downloadAndProcessExtraFiles()
                                     throws IOException

Overrides:

downloadAndProcessExtraFiles in class FileAwareFactoryFn<Consumer<byte[],byte[]>>

Throws:

IOException - A hook for subclasses to download and process specific files before the main configuration is handled. For example, the kerberos factory can use this to download a krb5.conf and set a system property.

processSecret

protected String processSecret(String originalValue,
 String secretId,
 byte[] secretValue)
                        throws RuntimeException

Overrides:

processSecret in class FileAwareFactoryFn<Consumer<byte[],byte[]>>

Throws:

RuntimeException