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

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

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

Related Packages

Package	Description
org.apache.beam.sdk.io.kafka	Transforms for reading and writing from Apache Kafka.
org.apache.beam.sdk.io.kafka.jmh	Benchmarks for KafkaIO.
org.apache.beam.sdk.io.kafka.serialization	Kafka serializers and deserializers.

Classes

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