org.apache.flink.table.store.kafka

Classes

• KafkaLogDeserializationSchema
• KafkaLogOptions
• KafkaLogSerializationSchema
• KafkaLogSinkProvider
• KafkaLogSourceProvider
• KafkaLogStoreFactory
• KafkaSinkFunction