Manage Kafka topics, schemas and permissions
Project description
Kafkalo is a tool to manage Kafka and Confluent Platform.
STATUS: while it does work, it is very rough around the edges. Consider this unstable and unreleased software for now.
It manages:
Topic creation and changes of settings
Schema creation and versioning.
Confluent RBAC rolebindings with predefined roles.
It also has a dry-run function that generates a plan. Whenever possible it will contact the services (for example Kafka broker with validate_only=True) and provide feedback on errors that will happen.
You provide a list of YAML input files (for example in a directory, with a glob pattern) and then Kafkalo will try to apply whatever is defined.
Usage
You can provide a config.yaml file so that kafkalo will know how to connect and possibly authenticate with your Kafka infrastrucure and related components (Schema registry, RBAC metadata server).
Look at sample config file included.
You can add input dirs with glob patterns to let kafkalo know where to find your YAML definitions. Kafkalo will read all the input YAMLs, merge then into a single internal data structure and try to sync them.
To generate a plan
> kafkalo plan
Once you are satisfied with the plan you can let kafkalo sync:
> kafkalo sync
Issues
History
0.1.0 (2021-02-23)
First release on PyPI.
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Hashes for kafkalo-0.1.0-py2.py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | f0095dd112d31ec04759c77818f9974182d3658307c18b90fa8652657450d08d |
|
MD5 | d7d85f066ebdb374d1140917ecc0202e |
|
BLAKE2b-256 | de0c8834bc6d7640e925e382cf2fdacdb6e97394be54b972e073887ba7909a3e |