> ## Documentation Index
> Fetch the complete documentation index at: https://docs.open-metadata.org/llms.txt
> Use this file to discover all available pages before exploring further.

# List Messaging Services

> List all messaging services with optional filtering and pagination

# List Messaging Services

List all messaging services with optional filtering and pagination.

## Query Parameters

<ParamField query="limit" type="integer" default="10">
  Maximum number of results to return (max: 1000000).
</ParamField>

<ParamField query="before" type="string">
  Cursor for backward pagination.
</ParamField>

<ParamField query="after" type="string">
  Cursor for forward pagination.
</ParamField>

<ParamField query="fields" type="string">
  Comma-separated list of fields to include. Valid fields: `pipelines`, `owners`, `tags`, `domains`, `followers`.
</ParamField>

<ParamField query="domain" type="string">
  Filter by domain fully qualified name.
</ParamField>

<ParamField query="include" type="string" default="non-deleted">
  Include `all`, `deleted`, or `non-deleted` entities.
</ParamField>

<RequestExample dropdown>
  ```python GET /v1/services/messagingServices theme={null}
  import requests

  base_url = "https://your-company.open-metadata.org/api"
  headers = {"Authorization": "Bearer your-jwt-token"}

  # List with pagination
  response = requests.get(
      f"{base_url}/v1/services/messagingServices",
      params={"limit": 50, "fields": "owners,tags"},
      headers=headers
  )
  page = response.json()
  for svc in page["data"]:
      print(f"{svc['name']} ({svc['serviceType']})")

  # Filter by domain
  response = requests.get(
      f"{base_url}/v1/services/messagingServices",
      params={"domain": "engineering", "limit": 50},
      headers=headers
  )
  ```

  ```java GET /v1/services/messagingServices theme={null}
  import static org.openmetadata.sdk.fluent.MessagingServices.*;

  // List services
  var result = MessagingServices.list()
      .fields("owners", "tags")
      .limit(50)
      .execute();

  for (MessagingService svc : result.getData()) {
      System.out.println(svc.getName() + " (" + svc.getServiceType() + ")");
  }
  ```

  ```bash GET /v1/services/messagingServices theme={null}
  # List all
  curl "{base_url}/api/v1/services/messagingServices?limit=50" \
    -H "Authorization: Bearer {access_token}"

  # With fields
  curl "{base_url}/api/v1/services/messagingServices?fields=owners,tags,domains&limit=50" \
    -H "Authorization: Bearer {access_token}"

  # Filter by domain
  curl "{base_url}/api/v1/services/messagingServices?domain=engineering&limit=50" \
    -H "Authorization: Bearer {access_token}"
  ```
</RequestExample>

<ResponseExample>
  ```json Response theme={null}
  {
    "data": [
      {
        "id": "469ef25e-9bdf-4d5f-8553-eb0ce8581f30",
        "name": "sample_kafka",
        "fullyQualifiedName": "sample_kafka",
        "serviceType": "Kafka",
        "connection": {
          "config": {
            "type": "Kafka",
            "bootstrapServers": "localhost:9092",
            "securityProtocol": "PLAINTEXT",
            "saslMechanism": "PLAIN",
            "schemaRegistryTopicSuffixName": "-value",
            "supportsMetadataExtraction": true
          }
        },
        "tags": [],
        "version": 0.1,
        "updatedAt": 1769982621031,
        "updatedBy": "admin",
        "href": "http://localhost:8585/api/v1/services/messagingServices/469ef25e-9bdf-4d5f-8553-eb0ce8581f30",
        "deleted": false,
        "owners": [],
        "domains": []
      }
    ],
    "paging": {
      "after": "eyJ...",
      "total": 3
    }
  }
  ```
</ResponseExample>

***

## Returns

Returns a paginated list of messaging service objects. By default, only basic fields are included. Use the `fields` parameter to request additional data.

## Response

<ResponseField name="data" type="array">
  Array of messaging service objects.

  <Expandable title="properties">
    <ResponseField name="id" type="string">
      Unique identifier for the messaging service (UUID format).
    </ResponseField>

    <ResponseField name="name" type="string">
      Messaging service name.
    </ResponseField>

    <ResponseField name="fullyQualifiedName" type="string">
      Fully qualified name of the service.
    </ResponseField>

    <ResponseField name="displayName" type="string">
      Human-readable display name.
    </ResponseField>

    <ResponseField name="serviceType" type="string">
      Type of messaging service (e.g., Kafka, Redpanda, Kinesis).
    </ResponseField>

    <ResponseField name="owners" type="array" optional>
      List of owners assigned to the service. Only included when `fields` contains `owners`.
    </ResponseField>

    <ResponseField name="tags" type="array" optional>
      Classification tags applied to the service. Only included when `fields` contains `tags`.
    </ResponseField>

    <ResponseField name="domains" type="array" optional>
      Domain assignments for governance. Only included when `fields` contains `domains`.
    </ResponseField>

    <ResponseField name="pipelines" type="array" optional>
      Ingestion pipelines associated with this service. Only included when `fields` contains `pipelines`.
    </ResponseField>

    <ResponseField name="followers" type="array" optional>
      Users following this service. Only included when `fields` contains `followers`.
    </ResponseField>
  </Expandable>
</ResponseField>

<ResponseField name="paging" type="object">
  Pagination information.

  <Expandable title="properties">
    <ResponseField name="total" type="integer">
      Total count of messaging services matching the query.
    </ResponseField>

    <ResponseField name="after" type="string" optional>
      Cursor for the next page of results. Null if this is the last page.
    </ResponseField>

    <ResponseField name="before" type="string" optional>
      Cursor for the previous page of results. Null if this is the first page.
    </ResponseField>
  </Expandable>
</ResponseField>