---
title: "List Recent Connections"
method: GET
path: "/v1/monitoring/kafka/connections"
tags: ["Monitoring"]
---

# List Recent Connections

`GET /v1/monitoring/kafka/connections`

List information on recent connections to the cluster.

## Query parameters

- `page_size` integer
- `filter` string
- `order_by` string

## Response `200`

Recent connections

- ListKafkaConnectionsResponse — ListKafkaConnectionsResponse is the response from the ListKafkaConnections RPC.
  - `connections` KafkaConnection[] — 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`.
    - `api_versions` object — This map records, for each Kafka API, the highest version number observed in requests on this connection. It can be useful for understanding which protocol versions a client supports or has negotiated with the broker. Only APIs that were actually used (i.e. at least one request was seen) are included. Example: { 0: 11, 1: 13 } means that for API key 0 (Produce), version 11 was the highest seen, and for API key 1 (Fetch), version 13 was the highest seen. Reference: - https://kafka.apache.org/0101/protocol.html#protocol_api_keys - https://kafka.apache.org/0101/protocol.html#protocol_compatibility
    - `authentication_info` AuthenticationInfo
      - `mechanism` 'AUTHENTICATION_MECHANISM_MTLS' | 'AUTHENTICATION_MECHANISM_SASL_SCRAM' | 'AUTHENTICATION_MECHANISM_SASL_OAUTHBEARER' | 'AUTHENTICATION_MECHANISM_SASL_PLAIN' | 'AUTHENTICATION_MECHANISM_SASL_GSSAPI'
      - `state` 'AUTHENTICATION_STATE_UNAUTHENTICATED' | 'AUTHENTICATION_STATE_SUCCESS' | 'AUTHENTICATION_STATE_FAILURE'
      - `user_principal` string
    - `client_id` string — Client identifier included in every request sent by the Kafka client. This is typically a configurable property (client.id) set by the application when creating a producer or consumer, and is often used for metrics, quotas, and debugging.
    - `client_software_name` string — Name of the client library, reported automatically in ApiVersions v3+ requests. This is set by the client implementation and is not typically configurable by applications.
    - `client_software_version` string — Version of the client library, reported automatically in ApiVersions v3+ requests. Like client_software_name, this is set by the client and not usually configurable by applications.
    - `close_time` string, date-time — When the connection was closed. This field is set only when the connection state is "closed".
    - `group_id` string — Most recent group ID seen in requests sent over this connection. This typically refers to a consumer group, but the Kafka group protocol is more general and may also be used by other types of clients that coordinate membership and assignments through the broker.
    - `group_instance_id` string — Most recent group instance ID seen in requests sent over this connection. This is used when static membership is enabled, allowing a specific client instance to retain its group membership across restarts.
    - `group_member_id` string — Most recent group member ID seen in requests sent over this connection. This is the unique identifier assigned by the broker to a particular member of the group.
    - `idle_duration` string
    - `in_flight_requests` InFlightRequests
      - `has_more_requests` boolean — Whether there are more in-flight requests than those in `sampled_in_flight_requests`.
      - `sampled_in_flight_requests` Request[]
        - `api_key` integer
        - `in_flight_duration` string
    - `listener_name` string — Name of the Kafka listener that accepted this connection. A listener is a named broker endpoint (for example, "internal", "external", or "sasl_tls"). Each listener defines its network address and enforces its protocol and authentication policy.
    - `node_id` integer
    - `open_time` string, date-time
    - `recent_request_statistics` RequestStatistics
      - `fetch_bytes` string, uint64 — Sum of bytes fetched.
      - `produce_batch_count` string, uint64
      - `produce_bytes` string, uint64 — Sum of bytes produced.
      - `request_count` string, uint64 — Number of requests the client has made.
    - `shard_id` integer
    - `source` Source
      - `ip_address` string
      - `port` integer
    - `state` 'KAFKA_CONNECTION_STATE_OPEN' | 'KAFKA_CONNECTION_STATE_ABORTING' | 'KAFKA_CONNECTION_STATE_CLOSED' — - KAFKA_CONNECTION_STATE_OPEN: The connection is accepting requests. - KAFKA_CONNECTION_STATE_ABORTING: The connection is aborting ongoing requests and about to be closed. This is a transient state between open and closed that should rarely be observable under normal circumstances. - KAFKA_CONNECTION_STATE_CLOSED: The connection has been closed.
    - `tls_info` TLSInfo
      - `enabled` boolean
    - `total_request_statistics` RequestStatistics
      - `fetch_bytes` string, uint64 — Sum of bytes fetched.
      - `produce_batch_count` string, uint64
      - `produce_bytes` string, uint64 — Sum of bytes produced.
      - `request_count` string, uint64 — Number of requests the client has made.
    - `transactional_id` string
    - `uid` string
  - `total_size` string, uint64

## Other responses

- `401` — Unauthenticated.
- `500` — Internal Server Error. Reach out to support.
- `default` — An unexpected error response.

## Changes

- **2025-11-10** `ce32b7444ffa` — 1 info
  - endpoint added
- **2025-05-27** `dfa71f9d277e` — 1 breaking
  - api path removed without deprecation

[Change history](https://skmtc.dev/redpanda-data/apis/redpanda-cloud-data-plane-api/changes/v1/monitoring/kafka/connections/get.md)

---

[API](https://skmtc.dev/redpanda-data/apis/redpanda-cloud-data-plane-api.md) · [All operations](https://skmtc.dev/redpanda-data/apis/redpanda-cloud-data-plane-api/llms.txt) · [OpenAPI document](https://skmtc-service-production.skmtc.workers.dev/v1/apis/redpanda-data/redpanda-cloud-data-plane-api/revisions/7eef0bcc42e7/schema)