View Source KafkaEx.Cluster.Topic (kafka_ex v1.0.0-rc.1)

Encapsulates what we know about a topic

Summary

Types

@type t() :: %KafkaEx.Cluster.Topic{
  is_internal: boolean(),
  name: String.t(),
  partition_leaders: %{required(integer()) => integer()},
  partitions: [KafkaEx.Cluster.PartitionInfo.t()]
}