Packages

c

fs2.kafka.KafkaAdminClient

ListConsumerGroupOffsets

sealed abstract class ListConsumerGroupOffsets[F[_]] extends AnyRef

Source
KafkaAdminClient.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ListConsumerGroupOffsets
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Abstract Value Members

  1. abstract def forPartitions[G[_]](partitions: G[TopicPartition])(implicit G: Foldable[G]): ListConsumerGroupOffsetsForPartitions[F]

    Only includes consumer group offsets for specified topic-partitions.

  2. abstract def partitionsToOffsetAndMetadata: F[Map[TopicPartition, OffsetAndMetadata]]

    Lists consumer group offsets for the consumer group.