Skip to content

Why does MessageSerializer have to encode a dict only? #4

Description

@mwong38

There are cases in a Kafka key, for example, that is a simple {"type": "string"} rather than a record. It would still be helpful to use the MessageSerializer. However, it doesn't permit non-dict's because of this check

        if not isinstance(record, dict):
            raise SerializerError("record must be a dictionary")

Any reason for this? Can it be removed?

Thanks.

Activity

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

      Milestone

      No milestone

      Relationships

      None yet

      Development

      No branches or pull requests

      Issue actions