pyflink.datastream.connectors.kafka.KafkaTopicPartition

class KafkaTopicPartition(topic: str, partition: int)

Corresponding to Java org.apache.kafka.common.TopicPartition class.

Example:

>>> topic_partition = KafkaTopicPartition('TOPIC1', 0)

Added in version 1.16.0.