org.apache.beam.sdk.io.kafka

Class KafkaIOInitializer

java.lang.Object

org.apache.beam.sdk.io.kafka.KafkaIOInitializer

All Implemented Interfaces:

JvmInitializer

@AutoService(value=JvmInitializer.class)
public class KafkaIOInitializer
extends java.lang.Object
implements JvmInitializer

Initialize KafkaIO feature flags on worker.

Constructor Summary

Constructors

Constructor and Description
KafkaIOInitializer()

Method Summary

Modifier and Type	Method and Description
void	beforeProcessing(PipelineOptions options) Implement beforeProcessing to run some custom initialization after basic services such as logging, but before data processing begins.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.beam.sdk.harness.JvmInitializer

onStartup

Constructor Detail

KafkaIOInitializer

public KafkaIOInitializer()

Method Detail

beforeProcessing

public void beforeProcessing(PipelineOptions options)

Description copied from interface: JvmInitializer

Implement beforeProcessing to run some custom initialization after basic services such as logging, but before data processing begins.

Specified by:

beforeProcessing in interface JvmInitializer

Parameters:

options - The pipeline options passed to the worker.