Uses of Class
org.apache.flink.statefun.sdk.kafka.KafkaTopicPartition

Packages that use KafkaTopicPartition

Package	Description
org.apache.flink.statefun.sdk.kafka

Uses of KafkaTopicPartition in org.apache.flink.statefun.sdk.kafka

Methods in org.apache.flink.statefun.sdk.kafka that return KafkaTopicPartition

Modifier and Type	Method and Description
static KafkaTopicPartition	KafkaTopicPartition.fromString(java.lang.String topicAndPartition)

Methods in org.apache.flink.statefun.sdk.kafka that return types with arguments of type KafkaTopicPartition

Modifier and Type	Method and Description
java.util.Map<KafkaTopicPartition,java.lang.Long>	KafkaIngressStartupPosition.SpecificOffsetsPosition.specificOffsets()

Method parameters in org.apache.flink.statefun.sdk.kafka with type arguments of type KafkaTopicPartition

Modifier and Type	Method and Description
static KafkaIngressStartupPosition	KafkaIngressStartupPosition.fromSpecificOffsets(java.util.Map<KafkaTopicPartition,java.lang.Long> specificOffsets) Start consuming from a specified set of offsets.