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 Tests Lint Coverage badge

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

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.

Source Distribution

kser-crypto-0.1.12.tar.gz (6.2 kB view hashes)

Uploaded Source

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page