# List Recent Connections

**GET /v1/monitoring/kafka/connections**

List information on recent connections to the cluster.


## Servers
- Data Plane API: https://{dataplane_api_subdomain}.cloud.redpanda.com (Data Plane API)


## Authentication methods
- Auth0


## Parameters


### Query parameters
- **page_size** (integer(int32))
  The maximum number of connections to return. If unspecified or 0, a
  default value may be applied. Note that paging is currently not fully
  supported, and this field only acts as a limit for the first page of data
  returned. Subsequent pages of data cannot be requested.
- **filter** (string)
  Filter expression to apply to the connection list.
  Uses a subset of AIP-160 filter syntax supporting:
  - Field comparisons (`=`, `!=`, `<`, `>`, `<=`, `>=`)
  - Logical AND chaining: condition1 AND condition2
  - Nested field access: parent.child = value
  - Escape sequences: field = "string with \"quotes\""
  - Enum types
  - RFC3339 timestamps and ISO-like duration

  Limitations (not supported):
  - Logical OR chaining
  - Parentheses `(` `)` for grouping
  - Map and repeated types
  - HAS (:) operator
  - Negation (-, NOT)
  - Bare literal matching

  Example filters:
  - `state = KAFKA_CONNECTION_STATE_OPEN`
  - `idle_duration > 30s AND total_request_statistics.request_count > 100`
  - `authentication_info.user_principal = "my-producer"`
  - `recent_request_statistics.produce_bytes > 1000 AND
  client_software_name = "kgo"`
  - `open_time >= 2025-09-01T10:22:54Z`

  Reference: https://google.aip.dev/160
- **order_by** (string)
  Field-based ordering specification following AIP-132 syntax.
  Supports multiple fields with `asc`/`desc` direction indicators.
  Examples:
  - `idle_duration desc` - longest idle connections first
  - `open_time desc, total_request_statistics.request_count desc` - newest
  connections first, then most active
  - `recent_request_statistics.produce_bytes desc` - connections with
  highest current produce throughput first

  Reference: https://google.aip.dev/132#ordering


## Responses
### 200
Recent connections

#### Body: application/json (object)
- **connections** (array[object])
  The list of connections matching the request.
  Note that in addition to open connections, some recently-closed
  connections may also be included here. If you don't want to include
  closed connections, set the filter in the request to `state =
  KAFKA_CONNECTION_STATE_OPEN`.
- **total_size** (string(uint64))


### 401
Unauthenticated.

#### Body: application/json (object)
- **code** (string(int32))
  RPC status code, as described [here](https://github.com/googleapis/googleapis/blob/b4c238feaa1097c53798ed77035bbfeb7fc72e96/google/rpc/code.proto#L32).
- **details** (array[object])
  A list of messages that carries the error details.
- **message** (string)
  Detailed error message. No compatibility guarantees are given for the text contained in this message.

### 500
Internal Server Error. Reach out to support.

#### Body: application/json (object)
- **code** (string(int32))
  RPC status code, as described [here](https://github.com/googleapis/googleapis/blob/b4c238feaa1097c53798ed77035bbfeb7fc72e96/google/rpc/code.proto#L32).
- **details** (array[object])
  A list of messages that carries the error details.
- **message** (string)
  Detailed error message. No compatibility guarantees are given for the text contained in this message.

### default
An unexpected error response.

#### Body: application/json (object)
- **code** (string(int32))
  RPC status code, as described [here](https://github.com/googleapis/googleapis/blob/b4c238feaa1097c53798ed77035bbfeb7fc72e96/google/rpc/code.proto#L32).
- **details** (array[object])
  A list of messages that carries the error details.
- **message** (string)
  Detailed error message. No compatibility guarantees are given for the text contained in this message.


[Powered by Bump.sh](https://bump.sh)