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

Class KafkaIOTranslation

java.lang.Object

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

public class KafkaIOTranslation
extends java.lang.Object

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

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	KAFKA_READ_WITH_METADATA_TRANSFORM_URN_V2
static java.lang.String	KAFKA_WRITE_TRANSFORM_URN_V2

Constructor Summary

Constructors

Constructor and Description
KafkaIOTranslation()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

KAFKA_READ_WITH_METADATA_TRANSFORM_URN_V2

public static final java.lang.String KAFKA_READ_WITH_METADATA_TRANSFORM_URN_V2

See Also:

Constant Field Values

KAFKA_WRITE_TRANSFORM_URN_V2

public static final java.lang.String KAFKA_WRITE_TRANSFORM_URN_V2

See Also:

Constant Field Values

Constructor Detail

KafkaIOTranslation

public KafkaIOTranslation()