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]

Note

Only kafka-python is implemented at the moment.

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

• PyPI: https://pypi.python.org/pypi/kser-crypto
• Project issues: https://github.com/cdumay/kser-crypto/issues

License

Licensed under MIT license (LICENSE or http://opensource.org/licenses/MIT)