1. 确认 AWS MSK 实例是否已经开启 Metrics。如果未开启，需要在实例的配置选项中开启 Metrics。

aws kafka update-cluster-configuration --cluster-arn  --cli-input-json '{"clusterName":"","configurationInfo":{"arn":"arn:aws:kafka:::configuration/default","revision":1}}'

2. 使用 CloudWatch 导航到 Metric Filters 页面，并创建一个 Metric Filter。Metric Filter 可以通过 CloudWatch Logs 提取指标并将其展示在 CloudWatch Metrics 中。 您可以使用以下示例 Metric Filters 按照 topicName 和 partition 提取指标。

{
  "metricTransformations": [
    {
      "metricName": "BrokerProduceRequestsPerSec",
      "metricNamespace": "AWS/Kafka",
      "metricValue": "$sum",
      "defaultValue": 0
    },
    {
      "metricName": "BrokerFetchRequestPerSec",
      "metricNamespace": "AWS/Kafka",
      "metricValue": "$sum",
      "defaultValue": 0
    }
  ],
  "filterPattern": "{ $.level = \"INFO\" && $.source = \"kafka.network.RequestChannel$\" && $.message = \"[Partition|Topic]\", \"[Partition|Topic]:\""
}

3. 在创建 Metric Filters 后，您可以使用 CloudWatch Metrics 查看从日志中提取的指标数据。

通过以上解决方法，您可以成功解决 AWS MSK (Kafka) 指标问题。