get_message
Read 1–500 Kafka messages at exact topic, partition and offset addresses in one call, with optional surrounding context; schema-encoded values are decoded to JSON.
Instructions
Read 1 to 500 Kafka messages at exact addresses in one call through items, and optionally nearby messages for context. Returns key, value, headers, timestamp and original value size.
Values carrying a Schema Registry id (Avro, Protobuf, JSON Schema) and topics with a configured format are decoded to JSON; format, schema_id and message_type say what the bytes were. Anything else is returned as text, or base64 when it is binary, and decode_error explains a value that named a schema but could not be decoded.
Results follow items order, each carrying index with result or error, so an invalid partition or an offset beyond the partition end is reported against its own item rather than failing the call. Reading one message is an items array of length one.
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| items | Yes | The message addresses to read, 1 to 500 of them. Reading one message is an array of length one. Results follow this order and an address that cannot be read is reported against its own item. |
Output Schema
| Name | Required | Description | Default |
|---|---|---|---|
| atomic | Yes | ||
| failed | Yes | ||
| applied | Yes | ||
| results | Yes | ||
| succeeded | Yes |