public class KafkaLogSourceProvider extends Object implements LogSourceProvider
LogSourceProvider
.Constructor and Description |
---|
KafkaLogSourceProvider(String topic,
Properties properties,
org.apache.flink.table.types.DataType physicalType,
int[] primaryKey,
org.apache.flink.api.common.serialization.DeserializationSchema<org.apache.flink.table.data.RowData> primaryKeyDeserializer,
org.apache.flink.api.common.serialization.DeserializationSchema<org.apache.flink.table.data.RowData> valueDeserializer,
int[][] projectFields,
CoreOptions.LogConsistency consistency,
CoreOptions.StartupMode scanMode,
Long timestampMills) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.connector.kafka.source.KafkaSource<org.apache.flink.table.data.RowData> |
createSource(Map<Integer,Long> bucketOffsets)
Creates a
Source instance. |
public KafkaLogSourceProvider(String topic, Properties properties, org.apache.flink.table.types.DataType physicalType, int[] primaryKey, @Nullable org.apache.flink.api.common.serialization.DeserializationSchema<org.apache.flink.table.data.RowData> primaryKeyDeserializer, org.apache.flink.api.common.serialization.DeserializationSchema<org.apache.flink.table.data.RowData> valueDeserializer, @Nullable int[][] projectFields, CoreOptions.LogConsistency consistency, CoreOptions.StartupMode scanMode, @Nullable Long timestampMills)
public org.apache.flink.connector.kafka.source.KafkaSource<org.apache.flink.table.data.RowData> createSource(@Nullable Map<Integer,Long> bucketOffsets)
LogSourceProvider
Source
instance.createSource
in interface LogSourceProvider
bucketOffsets
- optional, configure if you need to specify the startup offset.Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.