Class TopicSubscription


  • public class TopicSubscription
    extends Object
    • Constructor Detail

      • TopicSubscription

        public TopicSubscription​(String configuredTopicName,
                                 Integer partitionId,
                                 Long seekToOffset,
                                 String seekToPosition)
    • Method Detail

      • getConfiguredTopicName

        public String getConfiguredTopicName()
      • getPartitionId

        public Integer getPartitionId()
      • getSeekToOffset

        public Long getSeekToOffset()
      • getTopicPartitions

        public Set<io.vertx.kafka.client.common.TopicPartition> getTopicPartitions()