CheckConsistency verifies that the argument topic config is consistent with the argument cluster, e.g.

FromConfigMap converts a string map from a Kafka topic to a TopicSettings instance.

LoadACLBytes loads an ACLConfig from YAML bytes.

LoadACLsFile loads one or more ACLConfigs from a path to a YAML file.

LoadClusterBytes loads a ClusterConfig from YAML bytes.

LoadClusterFile loads a ClusterConfig from a path to a YAML file.

LoadTopicBytes loads a TopicConfig from YAML bytes.

LoadTopicsFile loads one or more TopicConfigs from a path to a YAML file.

TopicConfigFromTopicInfo generates a TopicConfig from a ClusterConfig and admin.TopicInfo struct generated from the cluster state.

PickerMethodClusterUse uses broker frequency in the topic, breaking ties by looking at the total number of replicas across the entire cluster that each broker appears in.

PickerMethodLowestIndex uses broker frequency in the topic, breaking ties by choosing the broker with the lowest index.

PickerMethodRandomized uses broker frequency in the topic, breaking ties by using a repeatably random choice from the options.

PlacementStrategyAny allows any partition placement.

PlacementStrategyBalancedLeaders is a strategy that ensures the leaders of each partition are balanced by rack, but does not care about the placements of the non-leader replicas.

PlacementStrategyCrossRack is a strategy in which the leaders are balanced and the replicas in each partition are spread to separate racks.

PlacementStrategyInRack is a strategy in which the leaders are balanced and the replicas for each partition are in the same rack as the leader.

PlacementStrategyStatic uses a static placement defined in the config.

PlacementStrategyStaticInRack is a strategy in which the replicas in each partition are chosen from the rack in a static list, but the specific replicas within each partition aren't specified.

ClusterConfig stores information about a cluster that's referred to by one or more topic configs.

ClusterMeta contains (mostly immutable) metadata about the cluster.

ClusterSpec contains the details necessary to communicate with a kafka cluster.

ResourceMeta stores the (mostly immutable) metadata associated with a resource.

SASLConfig contains the details required to use SASL to authenticate cluster clients.

TLSConfig contains the details required to use TLS in communication with broker clients.

TopicConfig represents the desired configuration of a topic.

TopicMigrationConfig configures the throttles and batch sizes used when running a partition migration.

TopicPlacementConfig describes how the partition replicas in a topic should be chosen.

TopicSpec stores the (mutable) specification for a topic.

PickerMethod is a string type that stores a picker method for breaking ties when choosing the replica placements for a topic.

PlacementStrategy is a string type that stores a replica placement strategy for a topic.

TopicSettings is a map of key/value pairs that correspond to Kafka topic config settings.