Class TopicSubscription
- java.lang.Object
-
- org.apache.camel.component.vertx.kafka.operations.TopicSubscription
-
public class TopicSubscription extends Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
TopicSubscription.OffsetPosition
-
Constructor Summary
Constructors Constructor Description TopicSubscription(String configuredTopicName, Integer partitionId, Long seekToOffset, String seekToPosition)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description String
getConfiguredTopicName()
Integer
getPartitionId()
Long
getSeekToOffset()
TopicSubscription.OffsetPosition
getSeekToPosition()
Set<io.vertx.kafka.client.common.TopicPartition>
getTopicPartitions()
Set<String>
getTopics()
-
-
-
Method Detail
-
getConfiguredTopicName
public String getConfiguredTopicName()
-
getPartitionId
public Integer getPartitionId()
-
getSeekToOffset
public Long getSeekToOffset()
-
getSeekToPosition
public TopicSubscription.OffsetPosition getSeekToPosition()
-
getTopicPartitions
public Set<io.vertx.kafka.client.common.TopicPartition> getTopicPartitions()
-
-