GET
/
admin
/
v1
/
topics
/
{topicName}
/
messages
[
  {
    "type": "PHASE",
    "message": {
      "partition": 123,
      "offset": 123,
      "timestamp": "2023-11-07T05:31:56Z",
      "timestampType": "NO_TIMESTAMP_TYPE",
      "key": "<string>",
      "headers": {},
      "content": "<string>",
      "keyFormat": "AVRO",
      "valueFormat": "AVRO",
      "keySize": 123,
      "valueSize": 123,
      "keySchemaId": "<string>",
      "valueSchemaId": "<string>",
      "headersSize": 123,
      "keySerde": "<string>",
      "valueSerde": "<string>",
      "keyDeserializeProperties": {},
      "valueDeserializeProperties": {}
    },
    "phase": {
      "name": "<string>"
    },
    "consuming": {
      "bytesConsumed": 123,
      "elapsedMs": 123,
      "isCancelled": true,
      "messagesConsumed": 123,
      "filterApplyErrors": 123
    }
  }
]

Path Parameters

topicName
string
required

Topic name

Query Parameters

seekType
enum<string>

Seek type

Available options:
BEGINNING,
OFFSET,
TIMESTAMP,
LATEST
seekTo
string[]

The format is [partition]::[offset] for specifying offsets or [partition]::[timestamp in millis] for specifying timestamps

limit
integer

Limit

q
string

Query

keySerde
string

Serde that should be used for deserialization. Supports String, Base64, Hex, SchemaRegistry, ProtobufDecodeRaw, and Avro (Embedded)

valueSerde
string

Serde that should be used for deserialization. Supports String, Base64, Hex, SchemaRegistry, ProtobufDecodeRaw, and Avro (Embedded)

Response

200
text/event-stream

OK

The response is of type object[].