Crypto Kafka serialize python library
Project description
kser-crypto
Kser module allow you to encrypt and decrypt messages in kafka using libsodium.
Quickstart
First, install kser-crypto using pip:
$ pip install kser-crypto[pykafka]
Examples
Make sure to have the environment variable KSER_SECRETBOX_KEY definded.
Consumer
from kser_crypto.python_kafka.consumer import CryptoConsumer
consumer = CryptoConsumer(config=dict(...), topics=[...])
consumer.run()
Producer
import time
from uuid import uuid4
from kser.schemas import Message
from kser_crypto.python_kafka.producer import CryptoProducer
producer = CryptoProducer(config=dict(...))
producer.send("test", Message(uuid=str(uuid4()), entrypoint="myTest"))
time.sleep(1)
Requirements
Python 3.x
Libsodium
Documentations
Project: http://kser.readthedocs.io/
Libsodium: https://download.libsodium.org/doc/
confluent-kafka-python: http://docs.confluent.io/current/clients/confluent-kafka-python
kafka-python: http://kafka-python.readthedocs.io/en/master/
Other links
Project issues: https://github.com/cdumay/kser-crypto/issues
License
Licensed under MIT license (LICENSE or http://opensource.org/licenses/MIT)
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.