MessageInfo

class kafkit.registry.MessageInfo(id, schema, message)

Bases: object

A message, along with schema information.

Parameters:

• id (int) – The ID of the schema (an int) in the Schema Registry. This uniquely identifies the message’s schema.

• schema (dict[str, Any]) – The schema, as a Python object.

• message (Any) – The message itself, as a decoded Python object.

id

The ID of the schema (an int) in the Schema Registry. This uniquely identifies the message’s schema.

schema

The schema, as a Python object.

message

The message itself, as a decoded Python object.