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.