Uses of Class
io.vertx.kafka.client.common.TopicPartition
-
-
Uses of TopicPartition in io.vertx.kafka.admin
Methods in io.vertx.kafka.admin that return types with arguments of type TopicPartition Modifier and Type Method Description Future<Map<TopicPartition,org.apache.kafka.clients.admin.DeletedRecords>>KafkaAdminClient. deleteRecords(Map<TopicPartition,org.apache.kafka.clients.admin.RecordsToDelete> recordsToDelete)Delete records from a topic partition.Set<TopicPartition>MemberAssignment. getTopicPartitions()default Future<Map<TopicPartition,OffsetAndMetadata>>KafkaAdminClient. listConsumerGroupOffsets(String groupId)List the consumer group offsets available in the cluster.Future<Map<TopicPartition,OffsetAndMetadata>>KafkaAdminClient. listConsumerGroupOffsets(String groupId, ListConsumerGroupOffsetsOptions options)List the consumer group offsets available in the cluster.Future<Map<TopicPartition,ListOffsetsResultInfo>>KafkaAdminClient. listOffsets(Map<TopicPartition,OffsetSpec> topicPartitionOffsets)List the offsets available for a set of partitions.List<TopicPartition>ListConsumerGroupOffsetsOptions. topicPartitions()Returns a list of topic partitions to add as part of the result.Method parameters in io.vertx.kafka.admin with type arguments of type TopicPartition Modifier and Type Method Description Future<Void>KafkaAdminClient. alterConsumerGroupOffsets(String groupId, Map<TopicPartition,OffsetAndMetadata> offsets)Alter committed offsets for a set of partitions in a consumer group.Future<Void>KafkaAdminClient. deleteConsumerGroupOffsets(String groupId, Set<TopicPartition> partitions)Delete committed offsets for a set of partitions in a consumer group.Future<Map<TopicPartition,org.apache.kafka.clients.admin.DeletedRecords>>KafkaAdminClient. deleteRecords(Map<TopicPartition,org.apache.kafka.clients.admin.RecordsToDelete> recordsToDelete)Delete records from a topic partition.Future<Map<TopicPartition,ListOffsetsResultInfo>>KafkaAdminClient. listOffsets(Map<TopicPartition,OffsetSpec> topicPartitionOffsets)List the offsets available for a set of partitions.MemberAssignmentMemberAssignment. setTopicPartitions(Set<TopicPartition> topicPartitions)Set the list of topic partitionsListConsumerGroupOffsetsOptionsListConsumerGroupOffsetsOptions. topicPartitions(List<TopicPartition> topicPartitions)Set the topic partitions to list as part of the result.Constructor parameters in io.vertx.kafka.admin with type arguments of type TopicPartition Constructor Description MemberAssignment(Set<TopicPartition> topicPartitions)Constructor -
Uses of TopicPartition in io.vertx.kafka.client.common
Methods in io.vertx.kafka.client.common that return TopicPartition Modifier and Type Method Description TopicPartitionTopicPartition. setPartition(int partition)Set the partition numberTopicPartitionTopicPartition. setTopic(String topic)Set the topic nameConstructors in io.vertx.kafka.client.common with parameters of type TopicPartition Constructor Description TopicPartition(TopicPartition that)Constructor (copy) -
Uses of TopicPartition in io.vertx.kafka.client.consumer
Methods in io.vertx.kafka.client.consumer that return types with arguments of type TopicPartition Modifier and Type Method Description Future<Set<TopicPartition>>KafkaConsumer. assignment()Get the set of partitions currently assigned to this consumer.Future<Map<TopicPartition,Long>>KafkaConsumer. beginningOffsets(Set<TopicPartition> topicPartitions)Get the first offset for the given partitions.Future<Map<TopicPartition,OffsetAndMetadata>>KafkaConsumer. commit(Map<TopicPartition,OffsetAndMetadata> offsets)Commit the specified offsets for the specified list of topics and partitions to Kafka.Future<Map<TopicPartition,Long>>KafkaConsumer. endOffsets(Set<TopicPartition> topicPartitions)Get the last offset for the given partitions.Future<Map<TopicPartition,OffsetAndTimestamp>>KafkaConsumer. offsetsForTimes(Map<TopicPartition,Long> topicPartitionTimestamps)Look up the offsets for the given partitions by timestamp.Future<Set<TopicPartition>>KafkaConsumer. paused()Get the set of partitions that were previously paused by a call to pause(Set).Methods in io.vertx.kafka.client.consumer with parameters of type TopicPartition Modifier and Type Method Description Future<Void>KafkaConsumer. assign(TopicPartition topicPartition)Manually assign a partition to this consumer.Future<Long>KafkaConsumer. beginningOffsets(TopicPartition topicPartition)Get the first offset for the given partitions.Future<OffsetAndMetadata>KafkaConsumer. committed(TopicPartition topicPartition)Get the last committed offset for the given partition (whether the commit happened by this process or another).Future<Long>KafkaConsumer. endOffsets(TopicPartition topicPartition)Get the last offset for the given partition.Future<OffsetAndTimestamp>KafkaConsumer. offsetsForTimes(TopicPartition topicPartition, Long timestamp)Look up the offset for the given partition by timestamp.Future<Void>KafkaConsumer. pause(TopicPartition topicPartition)Suspend fetching from the requested partition.Future<Long>KafkaConsumer. position(TopicPartition partition)Get the offset of the next record that will be fetched (if a record with that offset exists).Future<Void>KafkaConsumer. resume(TopicPartition topicPartition)Resume specified partition which have been paused with pause.Future<Void>KafkaConsumer. seek(TopicPartition topicPartition, long offset)Overrides the fetch offsets that the consumer will use on the next poll.Future<Void>KafkaConsumer. seek(TopicPartition topicPartition, OffsetAndMetadata offsetAndMetadata)Overrides the fetch offsets that the consumer will use on the next poll.Future<Void>KafkaConsumer. seekToBeginning(TopicPartition topicPartition)Seek to the first offset for each of the given partition.Future<Void>KafkaConsumer. seekToEnd(TopicPartition topicPartition)Seek to the last offset for each of the given partition.Method parameters in io.vertx.kafka.client.consumer with type arguments of type TopicPartition Modifier and Type Method Description Future<Void>KafkaConsumer. assign(Set<TopicPartition> topicPartitions)Manually assign a list of partition to this consumer.Future<Map<TopicPartition,Long>>KafkaConsumer. beginningOffsets(Set<TopicPartition> topicPartitions)Get the first offset for the given partitions.Future<Map<TopicPartition,OffsetAndMetadata>>KafkaConsumer. commit(Map<TopicPartition,OffsetAndMetadata> offsets)Commit the specified offsets for the specified list of topics and partitions to Kafka.Future<Map<TopicPartition,Long>>KafkaConsumer. endOffsets(Set<TopicPartition> topicPartitions)Get the last offset for the given partitions.Future<Map<TopicPartition,OffsetAndTimestamp>>KafkaConsumer. offsetsForTimes(Map<TopicPartition,Long> topicPartitionTimestamps)Look up the offsets for the given partitions by timestamp.KafkaConsumer<K,V>KafkaConsumer. partitionsAssignedHandler(Handler<Set<TopicPartition>> handler)Set the handler called when topic partitions are assigned to the consumerKafkaConsumer<K,V>KafkaConsumer. partitionsRevokedHandler(Handler<Set<TopicPartition>> handler)Set the handler called when topic partitions are revoked to the consumerFuture<Void>KafkaConsumer. pause(Set<TopicPartition> topicPartitions)Suspend fetching from the requested partitions.Future<Void>KafkaConsumer. resume(Set<TopicPartition> topicPartitions)Resume specified partitions which have been paused with pause.Future<Void>KafkaConsumer. seekToBeginning(Set<TopicPartition> topicPartitions)Seek to the first offset for each of the given partitions.Future<Void>KafkaConsumer. seekToEnd(Set<TopicPartition> topicPartitions)Seek to the last offset for each of the given partitions. -
Uses of TopicPartition in io.vertx.reactivex.kafka.admin
Method parameters in io.vertx.reactivex.kafka.admin with type arguments of type TopicPartition Modifier and Type Method Description Future<Void>KafkaAdminClient. deleteConsumerGroupOffsets(String groupId, Set<TopicPartition> partitions)Delete committed offsets for a set of partitions in a consumer group.CompletableKafkaAdminClient. rxDeleteConsumerGroupOffsets(String groupId, Set<TopicPartition> partitions)Delete committed offsets for a set of partitions in a consumer group. -
Uses of TopicPartition in io.vertx.reactivex.kafka.client.consumer
Methods in io.vertx.reactivex.kafka.client.consumer that return types with arguments of type TopicPartition Modifier and Type Method Description Future<Set<TopicPartition>>KafkaConsumer. assignment()Get the set of partitions currently assigned to this consumer.Future<Set<TopicPartition>>KafkaConsumer. paused()Get the set of partitions that were previously paused by a call to pause(Set).Single<Set<TopicPartition>>KafkaConsumer. rxAssignment()Get the set of partitions currently assigned to this consumer.Single<Set<TopicPartition>>KafkaConsumer. rxPaused()Get the set of partitions that were previously paused by a call to pause(Set).Methods in io.vertx.reactivex.kafka.client.consumer with parameters of type TopicPartition Modifier and Type Method Description Future<Void>KafkaConsumer. assign(TopicPartition topicPartition)Manually assign a partition to this consumer.Future<Long>KafkaConsumer. beginningOffsets(TopicPartition topicPartition)Get the first offset for the given partitions.Future<OffsetAndMetadata>KafkaConsumer. committed(TopicPartition topicPartition)Get the last committed offset for the given partition (whether the commit happened by this process or another).Future<Long>KafkaConsumer. endOffsets(TopicPartition topicPartition)Get the last offset for the given partition.Future<OffsetAndTimestamp>KafkaConsumer. offsetsForTimes(TopicPartition topicPartition, Long timestamp)Look up the offset for the given partition by timestamp.Future<Void>KafkaConsumer. pause(TopicPartition topicPartition)Suspend fetching from the requested partition.Future<Long>KafkaConsumer. position(TopicPartition partition)Get the offset of the next record that will be fetched (if a record with that offset exists).Future<Void>KafkaConsumer. resume(TopicPartition topicPartition)Resume specified partition which have been paused with pause.CompletableKafkaConsumer. rxAssign(TopicPartition topicPartition)Manually assign a partition to this consumer.Single<Long>KafkaConsumer. rxBeginningOffsets(TopicPartition topicPartition)Get the first offset for the given partitions.Single<OffsetAndMetadata>KafkaConsumer. rxCommitted(TopicPartition topicPartition)Get the last committed offset for the given partition (whether the commit happened by this process or another).Single<Long>KafkaConsumer. rxEndOffsets(TopicPartition topicPartition)Get the last offset for the given partition.Single<OffsetAndTimestamp>KafkaConsumer. rxOffsetsForTimes(TopicPartition topicPartition, Long timestamp)Look up the offset for the given partition by timestamp.CompletableKafkaConsumer. rxPause(TopicPartition topicPartition)Suspend fetching from the requested partition.Single<Long>KafkaConsumer. rxPosition(TopicPartition partition)Get the offset of the next record that will be fetched (if a record with that offset exists).CompletableKafkaConsumer. rxResume(TopicPartition topicPartition)Resume specified partition which have been paused with pause.CompletableKafkaConsumer. rxSeek(TopicPartition topicPartition, long offset)Overrides the fetch offsets that the consumer will use on the next poll.CompletableKafkaConsumer. rxSeek(TopicPartition topicPartition, OffsetAndMetadata offsetAndMetadata)Overrides the fetch offsets that the consumer will use on the next poll.CompletableKafkaConsumer. rxSeekToBeginning(TopicPartition topicPartition)Seek to the first offset for each of the given partition.CompletableKafkaConsumer. rxSeekToEnd(TopicPartition topicPartition)Seek to the last offset for each of the given partition.Future<Void>KafkaConsumer. seek(TopicPartition topicPartition, long offset)Overrides the fetch offsets that the consumer will use on the next poll.Future<Void>KafkaConsumer. seek(TopicPartition topicPartition, OffsetAndMetadata offsetAndMetadata)Overrides the fetch offsets that the consumer will use on the next poll.Future<Void>KafkaConsumer. seekToBeginning(TopicPartition topicPartition)Seek to the first offset for each of the given partition.Future<Void>KafkaConsumer. seekToEnd(TopicPartition topicPartition)Seek to the last offset for each of the given partition.Method parameters in io.vertx.reactivex.kafka.client.consumer with type arguments of type TopicPartition Modifier and Type Method Description Future<Void>KafkaConsumer. assign(Set<TopicPartition> topicPartitions)Manually assign a list of partition to this consumer.KafkaConsumer<K,V>KafkaConsumer. partitionsAssignedHandler(Handler<Set<TopicPartition>> handler)Set the handler called when topic partitions are assigned to the consumerKafkaConsumer<K,V>KafkaConsumer. partitionsRevokedHandler(Handler<Set<TopicPartition>> handler)Set the handler called when topic partitions are revoked to the consumerFuture<Void>KafkaConsumer. pause(Set<TopicPartition> topicPartitions)Suspend fetching from the requested partitions.Future<Void>KafkaConsumer. resume(Set<TopicPartition> topicPartitions)Resume specified partitions which have been paused with pause.CompletableKafkaConsumer. rxAssign(Set<TopicPartition> topicPartitions)Manually assign a list of partition to this consumer.CompletableKafkaConsumer. rxPause(Set<TopicPartition> topicPartitions)Suspend fetching from the requested partitions.CompletableKafkaConsumer. rxResume(Set<TopicPartition> topicPartitions)Resume specified partitions which have been paused with pause.CompletableKafkaConsumer. rxSeekToBeginning(Set<TopicPartition> topicPartitions)Seek to the first offset for each of the given partitions.CompletableKafkaConsumer. rxSeekToEnd(Set<TopicPartition> topicPartitions)Seek to the last offset for each of the given partitions.Future<Void>KafkaConsumer. seekToBeginning(Set<TopicPartition> topicPartitions)Seek to the first offset for each of the given partitions.Future<Void>KafkaConsumer. seekToEnd(Set<TopicPartition> topicPartitions)Seek to the last offset for each of the given partitions. -
Uses of TopicPartition in io.vertx.rxjava3.kafka.admin
Method parameters in io.vertx.rxjava3.kafka.admin with type arguments of type TopicPartition Modifier and Type Method Description CompletableKafkaAdminClient. deleteConsumerGroupOffsets(String groupId, Set<TopicPartition> partitions)Delete committed offsets for a set of partitions in a consumer group.CompletableKafkaAdminClient. rxDeleteConsumerGroupOffsets(String groupId, Set<TopicPartition> partitions)Delete committed offsets for a set of partitions in a consumer group. -
Uses of TopicPartition in io.vertx.rxjava3.kafka.client.consumer
Methods in io.vertx.rxjava3.kafka.client.consumer that return types with arguments of type TopicPartition Modifier and Type Method Description Single<Set<TopicPartition>>KafkaConsumer. assignment()Get the set of partitions currently assigned to this consumer.Single<Set<TopicPartition>>KafkaConsumer. paused()Get the set of partitions that were previously paused by a call to pause(Set).Single<Set<TopicPartition>>KafkaConsumer. rxAssignment()Get the set of partitions currently assigned to this consumer.Single<Set<TopicPartition>>KafkaConsumer. rxPaused()Get the set of partitions that were previously paused by a call to pause(Set).Methods in io.vertx.rxjava3.kafka.client.consumer with parameters of type TopicPartition Modifier and Type Method Description CompletableKafkaConsumer. assign(TopicPartition topicPartition)Manually assign a partition to this consumer.Single<Long>KafkaConsumer. beginningOffsets(TopicPartition topicPartition)Get the first offset for the given partitions.Single<OffsetAndMetadata>KafkaConsumer. committed(TopicPartition topicPartition)Get the last committed offset for the given partition (whether the commit happened by this process or another).Single<Long>KafkaConsumer. endOffsets(TopicPartition topicPartition)Get the last offset for the given partition.Single<OffsetAndTimestamp>KafkaConsumer. offsetsForTimes(TopicPartition topicPartition, Long timestamp)Look up the offset for the given partition by timestamp.CompletableKafkaConsumer. pause(TopicPartition topicPartition)Suspend fetching from the requested partition.Single<Long>KafkaConsumer. position(TopicPartition partition)Get the offset of the next record that will be fetched (if a record with that offset exists).CompletableKafkaConsumer. resume(TopicPartition topicPartition)Resume specified partition which have been paused with pause.CompletableKafkaConsumer. rxAssign(TopicPartition topicPartition)Manually assign a partition to this consumer.Single<Long>KafkaConsumer. rxBeginningOffsets(TopicPartition topicPartition)Get the first offset for the given partitions.Single<OffsetAndMetadata>KafkaConsumer. rxCommitted(TopicPartition topicPartition)Get the last committed offset for the given partition (whether the commit happened by this process or another).Single<Long>KafkaConsumer. rxEndOffsets(TopicPartition topicPartition)Get the last offset for the given partition.Single<OffsetAndTimestamp>KafkaConsumer. rxOffsetsForTimes(TopicPartition topicPartition, Long timestamp)Look up the offset for the given partition by timestamp.CompletableKafkaConsumer. rxPause(TopicPartition topicPartition)Suspend fetching from the requested partition.Single<Long>KafkaConsumer. rxPosition(TopicPartition partition)Get the offset of the next record that will be fetched (if a record with that offset exists).CompletableKafkaConsumer. rxResume(TopicPartition topicPartition)Resume specified partition which have been paused with pause.CompletableKafkaConsumer. rxSeek(TopicPartition topicPartition, long offset)Overrides the fetch offsets that the consumer will use on the next poll.CompletableKafkaConsumer. rxSeek(TopicPartition topicPartition, OffsetAndMetadata offsetAndMetadata)Overrides the fetch offsets that the consumer will use on the next poll.CompletableKafkaConsumer. rxSeekToBeginning(TopicPartition topicPartition)Seek to the first offset for each of the given partition.CompletableKafkaConsumer. rxSeekToEnd(TopicPartition topicPartition)Seek to the last offset for each of the given partition.CompletableKafkaConsumer. seek(TopicPartition topicPartition, long offset)Overrides the fetch offsets that the consumer will use on the next poll.CompletableKafkaConsumer. seek(TopicPartition topicPartition, OffsetAndMetadata offsetAndMetadata)Overrides the fetch offsets that the consumer will use on the next poll.CompletableKafkaConsumer. seekToBeginning(TopicPartition topicPartition)Seek to the first offset for each of the given partition.CompletableKafkaConsumer. seekToEnd(TopicPartition topicPartition)Seek to the last offset for each of the given partition.Method parameters in io.vertx.rxjava3.kafka.client.consumer with type arguments of type TopicPartition Modifier and Type Method Description CompletableKafkaConsumer. assign(Set<TopicPartition> topicPartitions)Manually assign a list of partition to this consumer.KafkaConsumer<K,V>KafkaConsumer. partitionsAssignedHandler(Handler<Set<TopicPartition>> handler)Set the handler called when topic partitions are assigned to the consumerKafkaConsumer<K,V>KafkaConsumer. partitionsRevokedHandler(Handler<Set<TopicPartition>> handler)Set the handler called when topic partitions are revoked to the consumerCompletableKafkaConsumer. pause(Set<TopicPartition> topicPartitions)Suspend fetching from the requested partitions.CompletableKafkaConsumer. resume(Set<TopicPartition> topicPartitions)Resume specified partitions which have been paused with pause.CompletableKafkaConsumer. rxAssign(Set<TopicPartition> topicPartitions)Manually assign a list of partition to this consumer.CompletableKafkaConsumer. rxPause(Set<TopicPartition> topicPartitions)Suspend fetching from the requested partitions.CompletableKafkaConsumer. rxResume(Set<TopicPartition> topicPartitions)Resume specified partitions which have been paused with pause.CompletableKafkaConsumer. rxSeekToBeginning(Set<TopicPartition> topicPartitions)Seek to the first offset for each of the given partitions.CompletableKafkaConsumer. rxSeekToEnd(Set<TopicPartition> topicPartitions)Seek to the last offset for each of the given partitions.CompletableKafkaConsumer. seekToBeginning(Set<TopicPartition> topicPartitions)Seek to the first offset for each of the given partitions.CompletableKafkaConsumer. seekToEnd(Set<TopicPartition> topicPartitions)Seek to the last offset for each of the given partitions.
-