Franzy-admin 0.0.1
A Kafka Clojure Admin client, with support for topic, partition, group, cluster management, and more.
Installation
To install, add the following dependency to your project or build file:
[ymilky/franzy-admin "0.0.1"]
Topics
Namespaces
franzy.admin.codec
Codec and supporting functionality for managing Kafka property-based configuration.
franzy.admin.partitions
Public variables and functions:
- all-topic-partitions
- isr-change-notification-path
- partition-epoch
- partition-in-sync-replicas
- partition-leader
- partition-leader-metadata
- partition-leaders-for
- partition-leaders-metadata
- partition-replica-assignment
- partitions-for
- partitions-undergoing-reassignment
- partitions-undergoing-replica-election
- reassign-partitions-path
- redefine-partition-count!
- replica-leader-election-path
- topic-partition-isr-leader-path
- topic-partition-path
- topic-partitions-path
- write-topic-partition-assignment-path!
franzy.admin.protocols
Experimental set of protocols for implementors that want a deftype, reified, record, component, etc.
Public variables and functions:
- BrokerCoordinator
- BrokerMetadataReader
- BrokerWriter
- ClientConfigurationReader
- ClientConfigurationWriter
- ClusterMetadataProvider
- ConsumerGroupReader
- ConsumerGroupWriter
- EntityConfigurationReader
- KafkaZookeeperMetadataProvider
- KafkaZookeeperWriter
- PartitionReplicaMetadataProvider
- TopicConfigurationReader
- TopicConfigurationWriter
- TopicPartitionReader
- TopicPartitionWriter
- TopicReader
- TopicReplicaMetadataProvider
- TopicWriter
franzy.admin.types
Types for working with Kafka servers.
Public variables and functions:
- ->Broker
- ->BrokerEndpoint
- ->ConsumerThreadId
- ->Endpoint
- ->LeaderAndIsr
- ->LeaderIsrAndControllerEpoch
- ->PartitionAndReplica
- ->PartitionMetadata
- ->ReassignedPartitionsContext
- ->TopicMetadata
- ->TopicMetadataResponse
- map->Broker
- map->BrokerEndpoint
- map->ConsumerThreadId
- map->Endpoint
- map->LeaderAndIsr
- map->LeaderIsrAndControllerEpoch
- map->PartitionAndReplica
- map->PartitionMetadata
- map->ReassignedPartitionsContext
- map->TopicMetadata
- map->TopicMetadataResponse
franzy.admin.zookeeper.paths
A collection of Kafka-specific Zookeeper calls, often used internally.
Public variables and functions: