Class | Description |
---|---|
KafkaLogDeserializationSchema |
A
KafkaDeserializationSchema for the table with primary key in log store. |
KafkaLogOptions |
Options for kafka log.
|
KafkaLogSerializationSchema |
A
KafkaRecordSerializationSchema for the table in log store. |
KafkaLogSinkProvider |
A Kafka
LogSinkProvider . |
KafkaLogSourceProvider |
A Kafka
LogSourceProvider . |
KafkaLogStoreFactory |
The Kafka
LogStoreTableFactory implementation. |
KafkaSinkFunction |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.