目录

Search

  1. 前言
  2. 命令行程序和实用程序
  3. 安装和配置命令行实用程序
  4. 使用命令行程序
  5. 命令行程序的环境变量
  6. 使用 infacmd
  7. infacmd as 命令引用
  8. infacmd aud 命令引用
  9. infacmd autotune 命令引用
  10. Infacmd bg 命令参考
  11. infacmd ccps 命令引用
  12. infacmd cluster 命令引用
  13. infacmd cms 命令引用
  14. infacmd dis 命令引用
  15. Infacmd dis 查询
  16. infacmd dp 命令引用
  17. infacmd idp 命令引用
  18. infacmd edp 命令引用
  19. Infacmd es 命令参考
  20. infacmd ics 命令引用
  21. infacmd ipc 命令引用
  22. infacmd isp 命令引用
  23. infacmd ldm 命令引用
  24. infacmd mas 命令引用
  25. infacmd mi 命令引用
  26. infacmd mrs 命令引用
  27. infacmd ms 命令引用
  28. infacmd oie 命令引用
  29. infacmd ps 命令引用
  30. infacmd pwx 命令引用
  31. infacmd roh 命令引用
  32. infacmd rms 命令参考
  33. infacmd rtm 命令引用
  34. infacmd sch 命令参考
  35. infacmd search 命令引用
  36. infacmd sql 命令引用
  37. infacmd tdm 命令引用
  38. infacmd tools 命令引用
  39. infacmd wfs 命令引用
  40. infacmd ws 命令引用
  41. infacmd xrf 命令引用
  42. infacmd 控制文件
  43. infasetup 命令引用
  44. pmcmd 命令引用
  45. pmrep 命令引用
  46. 使用 filemanager
  47. 处理 pmrep 文件

Kafka 连接选项

Kafka 连接选项

使用连接选项定义 Kafka 连接。
按以下格式输入连接选项:
... -o option_name=value option_name=value ...
要输入多个选项,请使用空格将它们分隔开。要输入包含空格或其他非字母数字字符的值,请使用引号将值引起来。
下表介绍了 infacmd isp CreateConnection 和 UpdateConnection 命令的 Kafka 连接选项:
选项
说明
connectionId
数据集成服务用来标识连接的字符串。ID 不区分大小写。不得超过 255 个字符,并且在域中必须唯一。不能在创建连接后更改此属性。默认值是连接名称。
connectionType
必需。连接类型为 KAFKA。
名称
必需。连接的名称。名称不区分大小写,但在域中必须唯一。可以在创建连接后更改此属性。名称不能超出 128 个字符,也不能包含空格或以下特殊字符:
~ ` ! $ % ^ & * ( ) - + = { [ } ] | \ : ; " ' < , > . ? /
connRetryTimeout
集成服务尝试重新连接到 Kafka Broker 的秒数。如果在指定的时间无法连接源或目标,将停止执行映射,以免丢失数据。
kafkaBrokerVersion
Kafka 消息传递 Broker 的版本。您可以输入以下值之一:
  • 0.10.1.x-2.0.0
kfkBrkList
Kafka 消息传递系统 Broker 列表的 IP 地址和端口组合。IP 地址和端口组合采用以下格式:
<IP Address>:<port>
可以输入多个以逗号分隔的 IP 地址和端口组合
zkHostPortList
用于维护 Kafka 消息传递 broker 的 Apache ZooKeeper 的 IP 地址和端口组合。IP 地址和端口组合采用以下格式:
<IP Address>:<port>
可以输入多个以逗号分隔的 IP 地址和端口组合。