Packages

c

fs2.kafka.KafkaAdminClient

DescribeCluster

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

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

Abstract Value Members

  1. abstract def clusterId: F[String]

    Current cluster ID.

  2. abstract def controller: F[Node]

    The node in the cluster acting as the current controller.

  3. abstract def nodes: F[Set[Node]]

    Lists available nodes in the cluster.