跳到主要内容 跳到补充内容

发布到 Kafka 时覆盖单个数据集的任务设置

发布到 Kafka 时,您可以覆盖单个数据集的数据消息发布和消息格式任务设置。

为此:

  1. 打开任务。在数据集 选项卡中,单击数据集右侧的 更多图标 菜单并选择设置

    数据集设置:<数据集名称> 对话框打开。

  2. 要覆盖数据消息发布设置,请选择数据消息发布选项卡,然后按照下面的覆盖数据消息发布设置中所述继续操作。

  3. 要覆盖消息格式设置,请选择消息格式选项卡,并按照下面的覆盖消息格式设置中所述继续操作。

覆盖数据消息发布设置

对于每个设置,当前任务设置由字段任务设置: <设置>指示(例如,任务设置: 特定主题)。

有关这些设置的说明,请参阅数据消息发布

您可以保留任务设置,或使用表达式构建器指定自定义主题、消息键或分区键。

要使用表达式构建器:

  1. 根据需要选择自定义主题自定义消息键自定义分区键字段,然后单击表达式图标

    信息注释自定义主题必须已经存在,或者必须配置代理以创建它们。

    表达式生成器已打开。

  2. 构建表达式。

    您可以使用数据集中的列、函数和运算符来构建表达式。

    单击 右箭头图标 以将项目移动到表达式中。

    您还可以在表达式中使用 Kafka 支持的所有函数。

  3. 单击提取参数

    现在,您可以将测试值添加所有参数的要测试的值

  4. 单击测试表达式

    现在应该可以使用测试值看到表达式的结果。

  5. 准备好后,单击确定

    表达式已添加到字段。

提示注释要删除添加的列,请选择该列并单击还原

构建表达式

您需要构建一个表达式来定义自定义值。您可以使用:

  • 源数据集中的所有列。

  • 函数

    字符串函数、数字函数、空校验函数、数据和时间函数以及逻辑函数。

  • 运算符

    数学和逻辑运算符表达式上方的工具栏中也提供了一些运算符。这也是查找字符串连接运算符的地方,||

单击 右箭头图标 以将项目移动到表达式中。

您还可以在表达式中使用 Kafka 支持的所有函数。

覆盖消息格式设置

要覆盖此数据集的任务消息属性,请启用使用自定义设置,然后按照消息属性中所述配置设置。

本页面有帮助吗?

如果您发现此页面或其内容有任何问题 – 打字错误、遗漏步骤或技术错误 – 请告诉我们!