franzy.admin.protocols — clj-kafka.franzy/admin 2.0.7

Experimental set of protocols for implementors that want a deftype, reified, record, component, etc.

BrokerCoordinator clj protocol

delete-broker-topic-path! clj

(delete-broker-topic-path! broker-id topic)

BrokerMetadataReader clj protocol

all-brokers clj

(all-brokers this)

broker-endpoints-for-channel clj

(broker-endpoints-for-channel this protocol-type)

broker-ids clj

(broker-ids this)

broker-metadata clj

(broker-metadata this broker-id)

BrokerWriter clj protocol

register-broker! clj

(register-broker! this broker-info)

(register-broker! this id host port endpoints jmx-port)

ClientConfigurationReader clj protocol

all-client-configs clj

(all-client-configs this)

ClientConfigurationWriter clj protocol

update-client-config! clj

(update-client-config! this)

ClusterMetadataProvider clj protocol

cluster-info clj

(cluster-info this)

ConsumerGroupReader clj protocol

consumer-group-active? clj

(consumer-group-active? this group)

consumer-groups clj

(consumer-groups this)

consumer-groups-by-topic clj

(consumer-groups-by-topic this topic)

consumer-groups-per-topic clj

(consumer-groups-per-topic this topic exclude-internal-topics?)

consumers-in-group clj

(consumers-in-group this group)

ConsumerGroupWriter clj protocol

delete-consumer-group! clj

(delete-consumer-group! this group)

delete-consumer-groups-for-topic! clj

(delete-consumer-groups-for-topic! this topic)

(delete-consumer-groups-for-topic! this topic group)

EntityConfigurationReader clj protocol

all-entity-configs clj

(all-entity-configs this config-type)

(all-entity-configs this config-type include-defaults?)

entity-config clj

(entity-config this config-type entity)

KafkaZookeeperMetadataProvider clj protocol

path-children clj

(path-children this path)

path-exists? clj

(path-exists? this path)

path-metadata clj

(path-metadata this path)

(path-metadata this path allow-null?)

persistent-paths clj

(persistent-paths this)

(persistent-paths this secure-paths?)

KafkaZookeeperWriter clj protocol

delete-path clj

(delete-path this path)

(delete-path this path recursive?)

PartitionReplicaMetadataProvider clj protocol

partition-leaders-for clj

(partition-leaders-for this topics)

partition-leader-metadata clj

(partition-leader-metadata this topic-partition)

(partition-leader-metadata this topic partition)

partitions-undergoing-replica-election clj

(partitions-undergoing-replica-election this)

topic-partition-in-sync-replicas clj

(topic-partition-in-sync-replicas this topic-partition)

(topic-partition-in-sync-replicas this topic partition)

partition-leader clj

(partition-leader this topic-partition)

(partition-leader this topic partition)

partition-leaders-metadata clj

(partition-leaders-metadata this topic-partitions)

partition-epoch clj

(partition-epoch this topic-partition)

(partition-epoch this topic partition)

partitions-undergoing-reassignment clj

(partitions-undergoing-reassignment this)

partition-replica-assignment clj

(partition-replica-assignment this topic-partition)

(partition-replica-assignment this topic partition)

TopicConfigurationReader clj protocol

all-topic-configs clj

(all-topic-configs this)

TopicConfigurationWriter clj protocol

update-topic-config! clj

(update-topic-config! this topic config)

TopicPartitionReader clj protocol

all-topic-partitions clj

(all-topic-partitions this)

partitions-for clj

(partitions-for this topics)

TopicPartitionWriter clj protocol

redefine-partition-count! clj

(redefine-partition-count! this topic partitions)

(redefine-partition-count! this
                           topic
                           partitions
                           replica-assignment
                           check-broker-available?)

TopicReader clj protocol

all-topics clj

(all-topics this)

topic-exists? clj

(topic-exists? this topic)

topics-by-consumer-group clj

(topics-by-consumer-group this group)

topics-metadata clj

(topics-metadata this topics)

TopicReplicaMetadataProvider clj protocol

topic-replica-assignment clj

(topic-replica-assignment this topic)

TopicWriter clj protocol

create-topic! clj

(create-topic! this topic partitions)

(create-topic! this topic partitions replication-factor)

(create-topic! this topic partitions replication-factor topic-config)

delete-topic! clj

(delete-topic! this topic)