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

Class KafkaIOTranslation

java.lang.Object

org.apache.beam.sdk.io.kafka.upgrade.KafkaIOTranslation

public class KafkaIOTranslation
extends Object

Utility methods for translating KafkaIO transforms to and from RunnerApi representations.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	KafkaIOTranslation.ReadRegistrar
static class	KafkaIOTranslation.WriteRegistrar

Field Summary

Fields

Modifier and Type	Field	Description
static final String	KAFKA_READ_WITH_METADATA_TRANSFORM_URN_V2
static final String	KAFKA_WRITE_TRANSFORM_URN_V2

Constructor Summary

Constructors

Constructor	Description
KafkaIOTranslation()

Method Summary

Methods inherited from class java.lang.Object

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

Field Details

KAFKA_READ_WITH_METADATA_TRANSFORM_URN_V2

public static final String KAFKA_READ_WITH_METADATA_TRANSFORM_URN_V2

See Also:

• Constant Field Values

KAFKA_WRITE_TRANSFORM_URN_V2

public static final String KAFKA_WRITE_TRANSFORM_URN_V2

See Also:

• Constant Field Values

Constructor Details

KafkaIOTranslation

public KafkaIOTranslation()