Skip to main content

Crypto Kafka serialize python library

Project description

Latest Version Latest version Documentation Status https://img.shields.io/badge/license-MIT-blue.svg

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

License

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

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Files for kser-crypto, version 0.1.5
Filename, size File type Python version Upload date Hashes
Filename, size kser-crypto-0.1.5.tar.gz (4.6 kB) File type Source Python version None Upload date Hashes View hashes

Supported by

Elastic Elastic Search Pingdom Pingdom Monitoring Google Google BigQuery Sentry Sentry Error logging AWS AWS Cloud computing DataDog DataDog Monitoring Fastly Fastly CDN SignalFx SignalFx Supporter DigiCert DigiCert EV certificate StatusPage StatusPage Status page