分布式消息服务Kafka版

前提条件

已在分布式消息服务Kafka版中购买Kafka实例

操作步骤

1. 登录事件网格控制台。
2. 在左侧导航栏选择“事件流”，进入“事件流”页面。
3. 单击“创建事件流”。
4. 在弹窗中输入事件流名称和描述，单击“确定”，完成事件流名称和描述信息输入。
5. 配置Kafka事件源。
   1. 单击“事件源”，右侧弹出“事件源”弹窗。
   2. 事件提供方选择“分布式消息服务 Kafka版”。
   3. 设置事件源参数。
      图1 事件源-Kafka
      

      表1 Kafka参数说明

      参数名称	说明
      实例	选择Kafka实例。
      接入方式	选择“密文接入”或“明文接入”。
      安全协议	当选择为密文接入时会显示对应的安全协议。
      Topic	选择Topic。
      消费组	输入消费组。
      并发数	输入并发数，输入值范围1~1000。 建议并发数与选择的Topic的分区数保持一致，如果不一致可能会影响消息消费速率。当您选择Topic时，如果并发数为空会读取您选择的Topic的分区数作为并发数。
      消费点位	选择消费点位。 最新点位：将会从消息队列的最新消息开始消费。 最早点位：将会从消息队列的最早消息开始消费。
      SASL认证机制	当Kafka实例开启SASL SSL时可见，选择SASL认证机制。 PLAIN：一种简单的用户名密码校验机制。 SCRAM-SHA-512：采用哈希算法对用户名与密码生成凭证，进行身份校验的安全认证机制，比PLAIN机制安全性更高。
      SASL证书地址	当Kafka实例开启SASL SSL时可见，输入SASL证书地址。获取地址请参考如何获取分布式消息服务Kafka实例的SASL证书地址。 说明： 必须使用zip压缩包，压缩包内的文件数量不超过两个，压缩包和文件大小均不可超过1M； 压缩包里证书的名称必须是固定的：client.jks。
      SASL证书密钥	当Kafka实例开启SASL SSL时可见，输入SASL证书密钥。
      用户名	当Kafka实例开启SASL SSL时可见，输入实例用户名。
      用户密码	当Kafka实例开启SASL SSL时可见，输入实例用户密码。

6. 单击“保存”，完成配置事件源。
7. 完成配置事件源后，您可以参考路由到函数工作流，继续配置事件流的事件目标。
8. 当事件源和事件目标都配置完成后，单击右上角“保存”，完成事件流的创建。
   

   发送到目标端失败时，将重试整批事件，直到处理成功或源端消息过期为止，目标端需支持处理重复事件。