Package | Description |
---|---|
org.apache.flink.table.descriptors |
Modifier and Type | Method and Description |
---|---|
Kafka |
Kafka.properties(Properties properties)
Sets the configuration properties for the Kafka consumer.
|
Kafka |
Kafka.property(String key,
String value)
Adds a configuration properties for the Kafka consumer.
|
Kafka |
Kafka.sinkPartitionerCustom(Class<? extends FlinkKafkaPartitioner> partitionerClass)
Configures how to partition records from Flink's partitions into Kafka's partitions.
|
Kafka |
Kafka.sinkPartitionerFixed()
Configures how to partition records from Flink's partitions into Kafka's partitions.
|
Kafka |
Kafka.sinkPartitionerRoundRobin()
Configures how to partition records from Flink's partitions into Kafka's partitions.
|
Kafka |
Kafka.startFromEarliest()
Configures to start reading from the earliest offset for all partitions.
|
Kafka |
Kafka.startFromGroupOffsets()
Configures to start reading from any committed group offsets found in Zookeeper / Kafka
brokers.
|
Kafka |
Kafka.startFromLatest()
Configures to start reading from the latest offset for all partitions.
|
Kafka |
Kafka.startFromSpecificOffset(int partition,
long specificOffset)
Configures to start reading partitions from specific offsets and specifies the given offset
for the given partition.
|
Kafka |
Kafka.startFromSpecificOffsets(Map<Integer,Long> specificOffsets)
Configures to start reading partitions from specific offsets, set independently for each
partition.
|
Kafka |
Kafka.startFromTimestamp(long startTimestampMillis)
Configures to start reading from partition offsets of the specified timestamp.
|
Kafka |
Kafka.topic(String topic)
Sets the topic from which the table is read.
|
Kafka |
Kafka.version(String version)
Sets the Kafka version to be used.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.