河南高端网站高端网站建设,网页设计制作心得体会,乡镇卫生院网站建设模板,中国手机最好的网站排名Kafka Node
Since TB Version 2.0 Kafka节点将消息发送到Kafka代理。它可以接收任何类型的消息。该节点会通过Kafka生产者将记录发送到Kafka服务器。 配置 主题模式 - 可以是静态字符串，也可以是使用消息元数据属性解析的模式。例如${deviceType}引导服务器 - 用逗号分隔的…Kafka Node
Since TB Version 2.0 Kafka节点将消息发送到Kafka代理。它可以接收任何类型的消息。该节点会通过Kafka生产者将记录发送到Kafka服务器。 配置
主题模式 - 可以是静态字符串，也可以是使用消息元数据属性解析的模式。例如${deviceType}引导服务器 - 用逗号分隔的kafka代理列表。自动重试次数 - 如果连接失败，重新发送消息的尝试次数。生成批量大小 - 用于将具有相同分区的消息分组的批量大小（按字节计）。本地缓冲时间 - 最大本地缓冲窗口持续时间(单位: 毫秒)。客户端缓冲最大大小 - 用于发送消息的最大缓冲区大小(按字节计)。确认数量 - 节点在考虑请求完成之前需要接收的确认数量。键序列化器 - 默认为org.apache.kafka.common.serialization.StringSerializer值序列化器 - 默认为org.apache.kafka.common.serialization.StringSerializer其他属性 - 可提供任何其他附加属性以进行与kafka代理的连接。发布的正文 - 节点将完整的消息负载发送到Kafka主题。如果需要，规则链可配置为使用转换节点链以正确发送有效负载到Kafka。
此节点的出站消息将在消息元数据中包含响应偏移量、分区和主题属性。原始消息负载、类型
