franzy.admin.protocols
Experimental set of protocols for implementors that want a deftype, reified, record, component, etc.
BrokerCoordinator
protocol
members
delete-broker-topic-path!
(delete-broker-topic-path! broker-id topic)BrokerMetadataReader
protocol
members
all-brokers
(all-brokers this)broker-endpoints-for-channel
(broker-endpoints-for-channel this protocol-type)broker-ids
(broker-ids this)broker-metadata
(broker-metadata this broker-id)BrokerWriter
protocol
members
register-broker!
(register-broker! this broker-info)(register-broker! this id host port endpoints jmx-port)ClientConfigurationReader
protocol
members
all-client-configs
(all-client-configs this)ClientConfigurationWriter
protocol
members
update-client-config!
(update-client-config! this)ClusterMetadataProvider
protocol
members
cluster-info
(cluster-info this)ConsumerGroupReader
protocol
members
consumer-group-active?
(consumer-group-active? this group)consumer-groups
(consumer-groups this)consumer-groups-by-topic
(consumer-groups-by-topic this topic)consumer-groups-per-topic
(consumer-groups-per-topic this topic exclude-internal-topics?)consumers-in-group
(consumers-in-group this group)ConsumerGroupWriter
protocol
members
delete-consumer-group!
(delete-consumer-group! this group)delete-consumer-groups-for-topic!
(delete-consumer-groups-for-topic! this topic)(delete-consumer-groups-for-topic! this topic group)EntityConfigurationReader
protocol
members
all-entity-configs
(all-entity-configs this config-type)(all-entity-configs this config-type include-defaults?)entity-config
(entity-config this config-type entity)KafkaZookeeperMetadataProvider
protocol
members
path-children
(path-children this path)path-exists?
(path-exists? this path)path-metadata
(path-metadata this path)(path-metadata this path allow-null?)persistent-paths
(persistent-paths this)(persistent-paths this secure-paths?)KafkaZookeeperWriter
protocol
members
delete-path
(delete-path this path)(delete-path this path recursive?)PartitionReplicaMetadataProvider
protocol
members
partition-epoch
(partition-epoch this topic-partition)(partition-epoch this topic partition)partition-leader
(partition-leader this topic-partition)(partition-leader this topic partition)partition-leader-metadata
(partition-leader-metadata this topic-partition)(partition-leader-metadata this topic partition)partition-leaders-for
(partition-leaders-for this topics)partition-leaders-metadata
(partition-leaders-metadata this topic-partitions)partition-replica-assignment
(partition-replica-assignment this topic-partition)(partition-replica-assignment this topic partition)partitions-undergoing-reassignment
(partitions-undergoing-reassignment this)partitions-undergoing-replica-election
(partitions-undergoing-replica-election this)topic-partition-in-sync-replicas
(topic-partition-in-sync-replicas this topic-partition)(topic-partition-in-sync-replicas this topic partition)TopicConfigurationReader
protocol
members
all-topic-configs
(all-topic-configs this)TopicConfigurationWriter
protocol
members
update-topic-config!
(update-topic-config! this topic config)TopicPartitionReader
protocol
members
all-topic-partitions
(all-topic-partitions this)partitions-for
(partitions-for this topics)TopicPartitionWriter
protocol
members
redefine-partition-count!
(redefine-partition-count! this topic partitions)(redefine-partition-count! this topic partitions replica-assignment check-broker-available?)TopicReader
protocol
members
all-topics
(all-topics this)topic-exists?
(topic-exists? this topic)topics-by-consumer-group
(topics-by-consumer-group this group)topics-metadata
(topics-metadata this topics)TopicReplicaMetadataProvider
protocol
members
topic-replica-assignment
(topic-replica-assignment this topic)TopicWriter
protocol
members
create-topic!
(create-topic! this topic partitions)(create-topic! this topic partitions replication-factor)(create-topic! this topic partitions replication-factor topic-config)delete-topic!
(delete-topic! this topic)