创建 Kafka 监听器

Apache Kafka 监听器连接器持续监控 Kafka 主题的信息。 当主题上产生消息时，监听器会获取消息并将其传递给监听器通知，以便进一步处理。

1. 转到要创建监听器的项目。
2. 单击事件 > 监听器。
3. 单击新建监听器。 出现 " 添加监听器 "屏幕。
4. 在 " 添加监听器 "屏幕中输入所需的详细信息。
   1. 在 " 监听器类型 "字段中，从列表中选择要创建监听器的 Kafka。
   2. 在选择版本字段中，选择连接器版本。
5. 在 "添加监听器 "配置页面的 " 监听器 "页面输入所需的详细信息。
   1. 在监听器名称字段中，提供监听 Kafka 主题上消息的监听器名称。
   2. 在连接名称字段中，指定监听器必须用来连接服务器以获取邮件的连接名称。 从连接列表中选择合适的用户连接。
      注意： 列表包含生产者和消费者连接。 选择用户连接。
   3. 在重试限制字段中，为监听器与 Kafka 服务器连接失败或失去连接时尝试重新连接的次数指定一个值。 默认值为 5。
   4. 在重试退避超时（毫秒） 字段中，指定重试限制中指定的每次重试之间必须经过的时间（以毫秒为单位）。 默认值为 10。

   监听器设置

   1. 在主题名称字段中，用逗号分隔指定 Kafka 监听器监听的主题列表。
   2. 在轮询间隔 (ms) 字段中，以毫秒为单位指定轮询间隔时间。 默认值为 10000。
   3. 在分区字段中，指定以逗号分隔的分区列表。
   4. 在 " 偏移量 "字段中，指定一个以逗号分隔的偏移量，消费者需要从这里开始消费报文。
      注：

      • 偏移量不能大于分区数。
      • 当提供多个分区或寻道偏移时，不支持多个主题订阅的监听器。
      • 如果未指定分区，偏移值将被忽略。
6. 在 “添加监听器 ”配置界面的 “高级设置 ”页面中输入所需信息。
   在 “监听器工作进程 ”字段中，指定您希望为监听器使用的并行监听器连接数。

   重要提示： 指定 1 将导致单线程行为，而指定较大的数值则会导致多线程监听器行为。 有关详细信息，请参阅《 使用多线程的 Kafka 监听器》
7. 单击下一步。 出现 " 概览 "页面。
8. 查看监听器配置详情。
9. 单击添加监听器。 监听器已保存并启用。
10. 单击 " 完成 "完成并关闭监听器配置，但不添加监听器通知。 如果要继续添加监听器通知，请单击 " 下一步 "。 如需了解更多信息，请参阅 “添加 Kafka 监听器通知”。