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

A library to support upgrading Kafka transforms without upgrading the pipeline.

See: Description

Class Summary

Class	Description
KafkaIOTranslation	Utility methods for translating KafkaIO transforms to and from RunnerApi representations.
KafkaIOTranslation.ReadRegistrar
KafkaIOTranslation.WriteRegistrar

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

A library to support upgrading Kafka transforms without upgrading the pipeline.