Pandaproxy API (0.0.2)
Create a consumer for the group.
path Parameters
group_name required | string |
Request Body schema: application/vnd.kafka.v2+json
format | string oneOf: ['binary','json'] |
name | string Name of the consumer |
auto.offset.reset | string oneOf: ['earliest'] |
auto.commit.enable | string oneOf: ['false'] |
fetch.min.bytes | string |
consumer.request.timeout.ms | string |
Responses
Request samples
- Payload
Content type
application/vnd.kafka.v2+json
{- "format": "string",
- "name": "string",
- "auto.offset.reset": "string",
- "auto.commit.enable": "string",
- "fetch.min.bytes": "string",
- "consumer.request.timeout.ms": "string"
}
Response samples
- 200
- 409
- 422
Content type
application/vnd.kafka.v2+json
{- "instance_id": "string",
- "base_uri": "string"
}
Get committed group offsets for given partitions.
path Parameters
group_name required | string |
instance required | string |
Request Body schema: application/vnd.kafka.v2+json
Array of objects | |||||
Array
|
Responses
Request samples
- Payload
Content type
application/vnd.kafka.v2+json
{- "partitions": [
- {
- "topic": "string",
- "partition": 0
}
]
}
Response samples
- 200
- 404
Content type
application/vnd.kafka.v2+json
{- "offsets": [
- {
- "topic": "string",
- "partition": 0,
- "offset": 0,
- "metadata": "string"
}
]
}
Commit offsets for a consumer.
path Parameters
group_name required | string |
instance required | string |
Request Body schema: application/vnd.kafka.v2+json
Array of objects | |||||||
Array
|
Responses
Request samples
- Payload
Content type
application/vnd.kafka.v2+json
{- "partitions": [
- {
- "topic": "string",
- "partition": 0,
- "offset": 0
}
]
}
Response samples
- 404
Content type
application/vnd.kafka.v2+json
{- "error_code": 0,
- "message": "string"
}
Produce messages to a topic.
path Parameters
topic_name required | string |
Request Body schema:
Array of objects | |||||||
Array
|
Responses
Request samples
- Payload
Content type
{- "records": [
- {
- "key": "string",
- "value": "string",
- "partition": 0
}
]
}
Response samples
- 200
Content type
application/vnd.kafka.v2+json
{- "offsets": [
- {
- "partition": 0,
- "offset": 0
}
]
}
Get records from a topic.
path Parameters
topic_name required | string |
partition_id required | integer |
query Parameters
offset required | integer |
timeout required | integer |
max_bytes required | integer |
Responses
Response samples
- 200
- 404
Content type
{- "records": [
- {
- "topic": "string",
- "key": "string",
- "value": "string",
- "partition": 0,
- "offset": 0
}
]
}