Packages

package admin

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Type Members

  1. trait MkAdminClient[F[_]] extends AnyRef

    A capability trait representing the ability to instantiate the Java AdminClient that underlies the fs2-kafka KafkaAdminClient.

    A capability trait representing the ability to instantiate the Java AdminClient that underlies the fs2-kafka KafkaAdminClient. This is needed in order to instantiate fs2.kafka.KafkaAdminClient.

    By default, the instance provided by MkAdminClient.mkAdminClientForSync will be used. However this behaviour can be overridden, e.g. for testing purposes, by placing an alternative implicit instance in lexical scope.

Value Members

  1. object MkAdminClient

Ungrouped