You need to enable JavaScript to run this app.
导航
消息队列 Kafka版
  • 文档首页
    • /
  • 消息队列 Kafka版

消息生产与消费

最近更新时间：2023.07.05 17:14:14

首次发布时间：2023.07.03 15:36:59

我的收藏

消息队列 Kafka版提供以下消息生产与消费相关的常见问题供您参考。

FAQ 列表

Kafka 实例是否支持延迟消息？

火山引擎消息队列 Kafka版暂不支持延迟消息。

如何查看正在消费消息的 IP 地址？

您可以参考以下步骤查看消费中的客户端 IP 地址：

  1. 登录消息队列 Kafka版控制台。
  2. 在顶部菜单栏中选择地域，并在选择左侧导航栏中单击实例列表。
  3. 找到目标实例，单击实例名称。
  4. 在顶部页签栏中单击Group管理，页签中展示当前实例下的 Group 列表。
  5. 单击 Group ID，查看指定 Group 的消费状态。
    在消费者状态区域中，展开 Topic，其中消费者信息一列即为正在消费消息的客户端 IP 地址。
    当消费者信息为空时，说明当前无客户端正在消费该分区，或者消费者使用的是第三方的 Kafka 客户端。

如何确定消息是否发送成功？

客户端发送消息到 Kafka 实例之后，您可以通过以下方式确认消息是否发送成功。

方式

说明

查询消息

在控制台消息查询页面，按位点或时间查询消息。如果可以正常查询到消息，表示消息发送成功。

查看 Topic 的存储消息数量

在控制台的Topic管理页面单击指定 Topic 的名称，在存储消息数量一列查看消息数量，如果和发送的消息数量一致，则表示消息发送成功。

查看回调

通常情况下，Kafka 客户端发送消息后，会通过回调方式返回 Callback 或 Future。如果成功收到正常的回调，表示消息发送成功。

Producer 建立的 Broker 连接数量是多少？

通常情况下，每个 Producer 会建立 2 个到 Broker 的 TCP 连接，分别用于更新元数据和发送消息。