@Internal public static interface KafkaRecordSerializationSchema.KafkaSinkContext
Modifier and Type | Method and Description |
---|---|
int |
getNumberOfParallelInstances() |
int |
getParallelInstanceId()
Get the ID of the subtask the KafkaSink is running on.
|
int[] |
getPartitionsForTopic(String topic)
For a given topic id retrieve the available partitions.
|
int getParallelInstanceId()
getNumberOfParallelInstances()
int getNumberOfParallelInstances()
int[] getPartitionsForTopic(String topic)
After the first retrieval the returned partitions are cached. If the partitions are updated the job has to be restarted to make the change visible.
topic
- kafka topic with partitionsCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.