Package org.apache.flink.formats.avro.registry.confluent.debezium
-
Class Summary Class Description DebeziumAvroDeserializationSchema Deserialization schema from Debezium Avro to Flink Table/SQL internal data structureRowData.DebeziumAvroFormatFactory Format factory for providing configured instances of Debezium Avro to RowDataDeserializationSchema.DebeziumAvroSerializationSchema Serialization schema from Flink Table/SQL internal data structureRowDatato Debezium Avro.