云服务器内容精选

  • 配置参数 表1 发送消息 参数 说明 主题 填写需要监听的topic。 Partition 消息将被写入的分区。 Key 消息Key值。 Message 消息内容。 Acks 发送确认参数。 all -1 0 1 KeySerializer 键的序列化方式,默认为org.apache.kafka.common.serialization.StringSerializer。 ValueSerializer 值的序列化方式,默认为org.apache.kafka.common.serialization.StringSerializer。 BufferMemorySize producer可以用来缓存数据的内存大小,默认为33554432。 Retries 重试次数。
  • 创建Kafka连接 登录新版ROMA Connect控制台。 在左侧导航栏选择“连接器”,在连接器页面单击“新建连接”。 选择“Kafka”连接器。 在弹窗中配置连接器信息,完成后单击“确定”。 参数 说明 连接名称 填写连接器实例名称。 Brokers地址 填写Kafka的Brokers地址。 认证方式 选择Kafka的认证方式。 SSL认证 无认证 SASL鉴权方式 仅当“认证方式”选择“SSL认证”时需要配置。 选择SASL鉴权方式。 PLAIN SC RAM -SHA-512 SSL用户名 仅当“认证方式”选择“SSL认证”时需要配置。 填写SSL用户名/应用Key。 SSL密码 仅当“认证方式”选择“SSL认证”时需要配置。 填写SSL密码。 SSL证书格式 仅当“认证方式”选择“SSL认证”时需要配置。 选择SSL证书格式。 PEM JKS SSL证书 仅当“认证方式”选择“SSL认证”时需要配置。 填写经过base64编码的证书内容。 SSL证书密码 仅当“认证方式”选择“SSL认证”时需要配置。 填写SSL证书密码。 描述 填写连接器的描述信息,用于识别不同的连接器。
  • 创建ArtemisMQ连接 登录新版ROMA Connect控制台。 在左侧导航栏选择“连接器”,在连接器页面单击“新建连接”。 选择“ArtemisMQ”连接器。 在弹窗中配置连接器信息,完成后单击“确定”。 参数 说明 连接名称 填写连接器实例名称。 主机IP地址 填写ArtemisMQ的连接IP地址。 端口 链接ArtemisMQ的端口号。 用户名 连接ArtemisMQ的用户名。 密码 连接ArtemisMQ的用户密码。 是否开启SSL认证 连接ArtemisMQ时是否使用SSL认证。 描述 填写连接器的描述信息,用于识别不同的连接器。