How to use the faust.serializers.codecs.Codec.__init__ function in faust

To help you get started, we’ve selected a few faust examples, based on popular ways it is used in public projects.

Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.

github marcosschroh / python-schema-registry-client / schema_registry / serializer / faust_avro_serializer.py View on Github external
def __init__(self, schema_registry_client, destination_topic, schema, is_key=False):
        self.schema_registry_client = schema_registry_client
        self.destination_topic = destination_topic
        self.schema = schema
        self.is_key = is_key

        # Initialize parents
        MessageSerializer.__init__(self, schema_registry_client)
        Codec.__init__(self)