Kafka 软件包 中的发布消息 操作

先决条件

• 使用连接 操作 建立的活动 Kafka 会话。 请参阅 Kafka 软件包 中的连接 操作。
• 目标 Kafka 主题存在于 broker 上，并且已认证用户对该主题具有生产者权限。

设置

使用发布消息 操作 将消息发送到活动会话中的 Apache Kafka 主题。 操作 接受一个可选的分区编号和消息键用于路由。 当未指定分区时，broker 使用默认分区器。 操作 返回一个包含数据的字典——包括主题名称、分区编号、偏移量和时间戳——可以在后续步骤中将其用于日志记录、审计或条件分支。

• 会话名称： 选择以下一个选项，以指定要使用的 Kafka 会话：
  • 会话名称： 选择由连接 操作 返回的活动 Kafka 会话，或接受默认会话名称 Default。
  • 变量： 选择一个包含活动 Kafka 会话配置的会话变量。
• 主题： 输入要消费的 Kafka 主题的确切名称。 例如，transactions-data。
• （可选）分区： 输入一个非负整数（0 或更大值）以指定特定分区。 如果您将此字段留空，broker 将使用默认分区器根据消息键或随机分配来确定分区。
• （可选）消息键： 输入由 broker 的分区器用于一致路由消息的消息键。 具有相同键的消息始终发送到同一分区。 使用有意义的标识符，例如客户 ID 或订单 ID。 例如，customer-id-7271。
• 消息： 输入要发布的消息内容。 支持多行输入。 该值可以是纯文本、JSON、XML，或消费应用程序接受的任何字符串格式。 例如，{"orderId": "ORD-9912", "status": "fulfilled", "amount": 149.99}。
  注： 避免包含未转义的特殊字符，以免使消费者期望的消息格式无效。
• 将输出分配到变量： 指定发布消息 操作 存储结果的变量。 发布消息 操作 返回一个包含已发布消息投递元数据的字典，包括主题名称、分区编号、偏移量和服务器分配的时间戳。 在下游步骤中使用此变量来访问诸如 topic、partition、offset 和 timestamp 等键，用于日志记录、审计或条件分支。