Kafka 软件包 中的提交偏移量 操作 使您能够为指定的主题、消费者组、分区和偏移量值显式提交消费者偏移量，确认该位置的消息已在您的自动化工作流中成功处理。
先决条件
- 在自动化中使用连接 操作 建立的活动 Kafka 会话。 请参阅 Kafka 软件包 中的连接 操作。
- 先前配置为手动提交策略的消费消息 操作。 当消费者手动管理偏移量时，提交偏移量 操作 才有意义。 请参阅 Kafka 软件包 中的消费消息 操作。
- 主题名称、消费者组 ID、分区编号和偏移量值均可用——通常从消费消息 操作 的输出中提取。 请参阅 Kafka 软件包 中的消费消息 操作。
设置
使用提交偏移量 操作 将特定消息的偏移量提交到 Kafka broker，以将其标记为已成功处理。 当提交策略设置为手动时，此 操作 与消费消息 操作 配合使用。 提交偏移量表示向 broker 表明，消费者已处理给定分区中直到该偏移量（包括该偏移量）为止的所有消息，因此消费者在下一次轮询时会从正确的位置恢复。 提交偏移量 操作 返回一个布尔值，表示提交是否成功。
-
会话名称： 选择以下一个选项，以指定要使用的 Kafka 会话：
- 会话名称： 选择由连接 操作 返回的活动 Kafka 会话，或接受默认会话名称 Default。
- 变量： 选择一个包含活动 Kafka 会话配置的会话变量。
- 主题： 输入您正在提交偏移量的 Kafka 主题名称。 这必须与对应的消费消息 操作 中使用的主题相匹配。
- 消费者组 ID： 输入用于跟踪已消费偏移量的消费者组标识符。 所有共享相同组 ID 的自动化共享分区分配和偏移量状态。 例如，erp-sync-group。
- 分区： 输入一个非负整数（0 或更大值），表示分区编号。 此值通常从消费消息 操作 的表格输出中提取。 例如，0。
- 偏移量： 输入一个非负整数，表示要提交的消息偏移量。 The offset needs to set as N+1 and committing offset indicates to the broker that all messages up to and including offset N have been processed. 此值通常从消费消息 操作 的表格输出中提取。 例如，142。
- 将输出分配到变量： 指定提交偏移量 操作 存储结果的变量。 提交偏移量 操作 返回一个布尔值。 值为 true 表示 broker 已为指定的主题、消费者组和分区记录了消费者的位置，确保下一步轮询从正确的偏移量恢复。 在后续步骤中使用此变量来实现错误处理或条件分支。