v50

latestOpenAPI 3.0.3raw.githubusercontent.com2026-08-0193273218.8 KB
Monitoring

List Recent Connections

List information on recent connections to the cluster.

get/v1/monitoring/kafka/connections

Query parameters

page_sizeinteger

The maximum number of connections to return. If unspecified or 0, a default value may be applied. The server may return fewer connections than requested due to memory constraints; the limit is set to allow listing all connections for a single broker. Consider filtering by node_id to view connections for specific brokers. 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.

filterstring

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_bystring

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

Response

Recent connections

total_sizestring uint64