KafkaConnector

该变压器接受任何功能。

这台变压器的输出将取决于执行的操作有所不同。消息数据被呈现为特征的属性。

• 之后接收动作，输出特征代表从集群接收的消息。
• 之后发送动作，输出特征代表发送到群集消息。
• 之后获取元数据动作，输出特性表示集群的状态。

传入的特性是通过这个端口输出的。

导致操作失败的特点是通过此端口输出。一个fme_rejection_code属性，具有该值ERROR_DURING_PROCESSING，将被添加，具有更多的描述性沿fme_rejection_message属性包含更具体的细节，以失败的原因。

注意:如果KafkaConnector已经有一个值fme_rejection_code，则此值将被删除。

被拒绝的功能处理：可以设置为终止翻译或继续当它遇到被拒绝的功能运行。此设置既可以作为默认FME选项并作为工作区参数。

引导服务器（主机和端口）的列表来连接。看到了“bootstrap.servers”配置选项https://kafka.apache.org/documentation.html欲获得更多信息。

主题

接受行为

接收选项

主题

发送选项

“消息选项”部分用于发送和接收消息，但有些选项仅在发送时可用。

元数据选项

获得的元数据只产生一个输出属性：_metadata。此属性包含JSON格式的元数据。格式为群集，经纪人，主题和分区的元数据的聚集。

{

“CLUSTER_ID”：<簇ID>，

“controller_broker_id”：<控制器代理ID>，

“经纪人”：

{

"id": < broker id >，

“宿主”：<主机>，

“端口”：<端口>

}，

…

]

“主题”:[

{

“名字”：<主题名称>，

“分区”：[

{

"id": <分区id >，

“leader_broker_id”：<前导经纪人ID>，

“replica_broker_ids”：[<副本代理ID>，...]，

“in_sync_replicas”：[<在同步复制品ID>，...]，

}，

…

]

}，

…

]

}

对于所有操作，都可以提供额外的高级选项。对于发送和接收，这些选项分别称为生产者和消费者。

选项被提供作为JSON对象，并匹配选项中的记录https://docs.confluent.io/current/clients/librdkafka/CONFIGURATION_8md.html。请注意，并非所有选项都可以在连接器的使用。

例

{

“socket.timeout.ms”：100，

“检查。crc”:真正的

}

如果与由连接器内部产生的那些的任何用户提供的选项的冲突，将要使用的用户提供的选项。例如，通常FME套“bootstrap.servers”但如果高级选项包含“bootstrap.servers”还有，该值将被用来代替。

以下属性可以被选择以包括在输出特征。输出的每个特征表示被发送或接收的消息。

使用文本编辑器

文本编辑器提供了一种方便的方法来构造来自各种数据源(如属性、参数和常量)的文本字符串(包括正则表达式)，其中直接在参数中使用结果。

文本编辑器

使用算术编辑器

算术编辑器提供了一个方便的方法来构造从各种数据源，如属性，参数和特征函数，其中结果被直接使用的参数内的数学表达式。

算术编辑器

有条件的值

根据通过或失败的一个或多个测试条件设置值。

参数条件定义对话框

内容

表达式和字符串可以包括多个功能，字符，参数等。

当设定值 - 无论是直接在参数输入或使用的编辑之一构造 - 字符串和表达式包含字符串，数学，日期/时间或FME特征函数将具有评价这些功能。因此，这些功能的名称（在形式@ <FUNCTION_NAME不应将>)用作文字字符串值。

内容类型

字符串函数	这些函数操作并格式化字符串。
特殊字符	一组控制字符在文本编辑器中提供。
数学函数	数学函数在两种编辑器中可用。
日期/时间函数	日期和时间函数是在文本编辑器中提供。
数学运算符	这些运营商都在算术编辑器中使用。
FME特性函数	这些返回的值主要是特性特定的值。
FME参数	FME和工作区特有的参数可被使用。
创建和修改用户参数	创建您自己的可编辑参数。

注意:并不是所有的工具都适用于所有的变压器。