OpenMSIStreamKafkaCrypto

class openmsistream.kafka_wrapper.OpenMSIStreamKafkaCrypto(broker_configs, config_file)

Bases: object

A wrapper class to own and work with the Producers, Consumers, and other objects needed by KafkaCrypto to handle encrypting/decrypting messages and exchanging keys

Parameters:

• broker_configs (dict) – the producer/consumer-agnostic configurations for connecting to the broker

• config_file (pathlib.Path) – the path to the KafkaCrypto config file for the node being used

property config_file_path

The path to the KafkaCrypto config file used

property key_serializer

The crypto key serializer

property key_deserializer

The crypto key deserializer

property value_serializer

The crypto value serializer

property value_deserializer

The crypto value deserializer

close()

Close the kafkacrypto.KafkaCrypto object and un-set its producer/consumer