Package org.apache.beam.sdk.io.kafka

Class KafkaIOInitializer

java.lang.Object

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

All Implemented Interfaces:

JvmInitializer

@AutoService(JvmInitializer.class)
public class KafkaIOInitializer
extends Object
implements JvmInitializer

Initialize KafkaIO feature flags on worker.

Constructor Summary

Constructors

Constructor	Description
KafkaIOInitializer()

Method Summary

Modifier and Type	Method	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 Details

KafkaIOInitializer

public KafkaIOInitializer()

Method Details

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.