object KafkaAdminClient
- Source
- KafkaAdminClient.scala
- Alphabetic
- By Inheritance
- KafkaAdminClient
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- sealed abstract class DescribeCluster[F[_]] extends AnyRef
- sealed abstract class ListConsumerGroupOffsets[F[_]] extends AnyRef
- sealed abstract class ListConsumerGroupOffsetsForPartitions[F[_]] extends AnyRef
- sealed abstract class ListConsumerGroups[F[_]] extends AnyRef
- sealed abstract class ListTopics[F[_]] extends AnyRef
- sealed abstract class ListTopicsIncludeInternal[F[_]] extends AnyRef
Value Members
- def resource[F[_]](settings: AdminClientSettings)(implicit F: Async[F], mk: MkAdminClient[F]): Resource[F, KafkaAdminClient[F]]
Creates a new KafkaAdminClient in the
Resource
context, using the specified AdminClientSettings.Creates a new KafkaAdminClient in the
Resource
context, using the specified AdminClientSettings. If working in aStream
context, you might prefer KafkaAdminClient.stream. - def resourceIn[F[_], G[_]](settings: AdminClientSettings)(implicit F: Sync[F], G: Async[G], mk: MkAdminClient[F]): Resource[F, KafkaAdminClient[G]]
Like resource, but allows the effect type of the created KafkaAdminClient to be different from the effect type of the Resource that allocates it.
- def stream[F[_]](settings: AdminClientSettings)(implicit F: Async[F], mk: MkAdminClient[F]): Stream[F, KafkaAdminClient[F]]
Creates a new KafkaAdminClient in the
Stream
context, using the specified AdminClientSettings.Creates a new KafkaAdminClient in the
Stream
context, using the specified AdminClientSettings. If you're not working in aStream
context, you might instead prefer to use the KafkaAdminClient.resource. - def streamIn[F[_], G[_]](settings: AdminClientSettings)(implicit F: Sync[F], G: Async[G], mk: MkAdminClient[F]): Stream[F, KafkaAdminClient[G]]
Like stream, but allows the effect type of the created KafkaAdminClient to be different from the effect type of the Stream that allocates it.