integration_test/third_party_apps_test/applications/kafka/metadata.yaml

# Copyright 2022 Google LLC
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
#      http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

public_url: "https://cloud.google.com/stackdriver/docs/solutions/agents/ops-agent/third-party/kafka"
app_url: "https://kafka.apache.org/"
short_name: Kafka
long_name: Apache Kafka
logo_path: /images/launcher/logos/kafka.png # supplied by google technical writer
description: |-
  The Apache Kafka integration collects broker metrics, such as topic requests and
  failures. It also monitors the partitions on the broker. The integration
  collects Kafka logs and parses them into a JSON payload. The result includes
  fields for logger, level, and message.
configure_integration: |-
  To expose a JMX endpoint, you must set the `com.sun.management.jmxremote.port`
  system property when starting the JVM. We also recommend setting the
  `com.sun.management.jmxremote.rmi.port` system property to the same port. To
  expose a JMX endpoint remotely, you must also set the `java.rmi.server.hostname`
  system property.

  By default, these properties are set in a Kafka deployment's
  `bin/kafka-run-class.sh` file.

  To set system properties by using command-line arguments, prepend the property
  name with `-D` when starting the JVM. For example, to set
  `com.sun.management.jmxremote.port` to port `9999`, specify the following when
  starting the JVM:

  <pre>
  -Dcom.sun.management.jmxremote.port=9999
  </pre>
minimum_supported_agent_version:
  metrics: 2.10.0
  logging: 2.10.0
supported_operating_systems: linux
supported_app_version: ["0.8 through 3.0.0", ""] # Indicate multiple versions.
expected_metrics:
  - type: workload.googleapis.com/kafka.isr.operation.count
    value_type: INT64
    kind: CUMULATIVE
    monitored_resources: [gce_instance]
    labels:
      - name: operation
        value_regex: .*
  - type: workload.googleapis.com/kafka.message.count
    value_type: INT64
    kind: CUMULATIVE
    monitored_resources: [gce_instance]
    representative: true
  - type: workload.googleapis.com/kafka.network.io
    value_type: INT64
    kind: CUMULATIVE
    monitored_resources: [gce_instance]
    labels:
      - name: state
        value_regex: .*
  - type: workload.googleapis.com/kafka.partition.count
    value_type: INT64
    kind: GAUGE
    monitored_resources: [gce_instance]
  - type: workload.googleapis.com/kafka.partition.offline
    value_type: INT64
    kind: GAUGE
    monitored_resources: [gce_instance]
  - type: workload.googleapis.com/kafka.partition.under_replicated
    value_type: INT64
    kind: GAUGE
    monitored_resources: [gce_instance]
  - type: workload.googleapis.com/kafka.purgatory.size
    value_type: INT64
    kind: GAUGE
    monitored_resources: [gce_instance]
    labels:
      - name: type
        value_regex: .*
  - type: workload.googleapis.com/kafka.request.count
    value_type: INT64
    kind: CUMULATIVE
    monitored_resources: [gce_instance]
    labels:
      - name: type
        value_regex: .*
  - type: workload.googleapis.com/kafka.request.failed
    value_type: INT64
    kind: CUMULATIVE
    monitored_resources: [gce_instance]
    labels:
      - name: type
        value_regex: .*
  - type: workload.googleapis.com/kafka.request.time.total
    value_type: INT64
    kind: CUMULATIVE
    monitored_resources: [gce_instance]
    labels:
      - name: type
        value_regex: .*
expected_logs:
  - log_name: kafka
    fields:
      - name: jsonPayload.message
        value_regex: .*Waiting until connected.*
        type: string
        description: 'Log message, including detailed stacktrace where provided'
      - name: jsonPayload.source
        value_regex: ZooKeeperClient Kafka server
        type: string
        description: 'Module and/or thread where the log originated.'
      - name: jsonPayload.logger
        value_regex: kafka.zookeeper.ZooKeeperClient
        type: string
        description: 'Name of the logger where the log originated.'
      - name: jsonPayload.level
        type: string
        description: Log entry level
        optional: true
      - name: severity
        type: string
        description: ''
configuration_options:
  logs:
    - type: kafka
      fields:
        - name: type
          default: null
          description: This value must be `kafka`.
        - name: include_paths
          default: '[/var/log/kafka/*.log]'
          description: A list of filesystem paths to read by tailing each file. A wild card (`*`) can be used in the paths; for example, `/var/log/kafka*/*.log`.
        - name: exclude_paths
          default: null
          description: A list of filesystem path patterns to exclude from the set matched by `include_paths`.
        - name: record_log_file_path
          default: false
          description: If set to `true`, then the path to the specific file from which the log record was obtained appears in the output log entry as the value of the `agent.googleapis.com/log_file_path` label. When using a wildcard, only the path of the file from which the record was obtained is recorded.
        - name: wildcard_refresh_interval
          default: 60s
          description: The interval at which wildcard file paths in `include_paths` are refreshed. Given as a [time duration](https://pkg.go.dev/time#ParseDuration), for example `30s` or `2m`. This property might be useful under high logging throughputs where log files are rotated faster than the default interval.
  metrics:
    - type: kafka
      fields:
        - name: type
          default: null
          description: This value must be `kafka`.
        - name: stub_status_url
          default: localhost:9999
          description: The [JMX Service URL](https://docs.oracle.com/javase/8/docs/api/javax/management/remote/JMXServiceURL.html) or host and port used to construct the service URL. This value must be in the form of `service:jmx:<protocol>:<sap>` or `host:port`. Values in `host:port` form are used to create a service URL of `service:jmx:rmi:///jndi/rmi://<host>:<port>/jmxrmi`.
        - name: collect_jvm_metrics
          default: true
          description: Configures the receiver to also collect the supported JVM metrics.
        - name: username
          default: null
          description: The configured username if JMX is configured to require authentication.
        - name: password
          default: null
          description: The configured password if JMX is configured to require authentication.
        - name: collection_interval
          default: 60s
          description: A [time duration](https://pkg.go.dev/time#ParseDuration) value, such as `30s` or `5m`.