跳到主要内容

使用Click-to-Connect连接到Apache Kafka

在 PubSub+ 事件代理管理器中，您可以使用 Click-to-Connect 向导以一种全面的方式创建集成的 Kafka 桥接，该方式会配置服务和连接的所有常见部分.

有关 PubSub+ 事件代理如何连接到 Apache Kafka 的详细信息，请参阅 Kafka 桥接.

先决条件锚点​

  • PubSub+ 事件代理版本 10.8.1 或更高版本，并已配置适当的系统和消息 VPN 扩展参数以启用 Kafka 桥接.

  • 访问 PubSub+ 事件代理管理器（请参阅访问事件代理管理器）.

  • 如果您正在为 PubSub+ Cloud 事件代理服务设置 REST 连接器，则需要生成一个 API 令牌，以便 Click-to-Connect 向导可以与事件代理服务进行身份验证.有关更多信息，请参阅为 Click-to-Connect 创建 API 令牌.

从 Apache Kafka 接收消息锚点​

要配置事件代理使用 Click-to-Connect 向导从 Apache Kafka 接收消息，请执行以下步骤：

  1. 登录到 PubSub+ 事件代理管理器.

  2. 选择一个消息 VPN.

  3. 在导航栏中点击 连接器向导.

  4. 点击 Apache.

  5. 点击 从 Apache Kafka 接收，然后点击 身份验证.

  6. 为连接器提供一个名称，并选择 身份验证方案.这是事件代理用于建立与远程 Kafka 集群连接的方案.根据您选择的方案，提供以下信息：

    • 无—不需要身份验证.此选项可能适用于匿名连接或 Kafka 接收器不需要身份验证的情况.

    • 基本—用户名和密码.

    • SCRAM—用户名、密码和 SCRAM 哈希.

    • 客户端证书—客户端证书的 PEM 格式内容和证书密码.

    • Kerberos—远程 Kafka 经纪人的服务名称、Kafka 接收器的用户主体名称和 Kafka 接收器的 keytab 文件.

    • OAuth—OAuth 客户端 ID、客户端密钥和令牌端点 URL.您还可以指定 OAuth 范围.

    有关这些身份验证方案的更多信息，请参阅为 Kafka 接收器配置身份验证方案.

  7. 点击 连接器设置，然后提供 启动 IP 地址列表.启动地址是 Kafka 集群中一个 Kafka 经纪人的完全限定域名（FQDN）或 IP 地址以及可选端口，Kafka 接收器可以从该地址获取整个集群的状态.您可以为 Kafka 接收器配置这些地址的列表，以便在尝试连接到一个地址失败时尝试连接到下一个地址.

  8. （可选）配置 TLS/SSL 加密.有关更多信息，请参阅为 Kafka 接收器连接启用 TLS/SSL 加密.

  9. 点击 主题设置，然后提供您想要从其接收消息的 Kafka 主题 的名称，并指定从该主题消费的 初始偏移量.

  10. 指定 Solace 主题映射.您通过提供一个替换表达式来完成此操作，该表达式为从 Kafka 接收到的每条消息生成 SMF 主题.有关替换表达式的更多信息，请参阅替换表达式概述.例如，您可以指定替换表达式 rectopic1，以便 Kafka 接收器从远程 Kafka 集群消费的所有消息都发布到事件代理上的此主题.

  11. （可选）指定 Solace 键映射.您通过提供一个替换表达式来完成此操作，该表达式为从 Kafka 接收到的每条消息生成分区键.此键确定消息发送到哪个队列分区.

  12. 点击 创建并启用连接器 以完成连接器的创建.

向 Apache Kafka 发送消息锚点​

要配置事件代理使用 Click-to-Connect 向导向 Apache Kafka 发送消息，请执行以下步骤：

  1. 登录到 PubSub+ 事件代理管理器.

  2. 选择一个消息 VPN.

  3. 在导航栏中点击 连接器向导.

  4. 点击 Apache.

  5. 点击 向 Apache Kafka 发送，然后点击 身份验证.

  6. 为连接器提供一个名称，并选择 身份验证方案.根据您选择的方案，提供以下信息：

    • 无—不需要身份验证.此选项可能适用于匿名连接或 Kafka 接收器不需要身份验证的情况.

    • 基本—用户名和密码.

    • SCRAM—用户名、密码和 SCRAM 哈希.

    • 客户端证书—客户端证书的 PEM 格式内容和证书密码.

    • Kerberos—远程 Kafka 经纪人的服务名称、Kafka 发送器的用户主体名称和 Kafka 发送器的 keytab 文件.

    • OAuth—OAuth 客户端 ID、客户端密钥和令牌端点 URL.您还可以指定 OAuth 范围.

    有关这些身份验证方案的更多信息，请参阅为 Kafka 发送器配置身份验证方案.

  7. 提供 启动 IP 地址列表.

  8. （可选）配置 TLS/SSL 加密.有关更多信息，请参阅为 Kafka 发送器连接启用 TLS/SSL 加密.

  9. 点击 订阅设置 并提供您想要向其发送消息的远程 Kafka 集群上的 Kafka 主题 的名称.

  10. （可选）指定 Kafka 键映射.您通过提供一个替换表达式来完成此操作，该表达式为发送到 Kafka 的每条消息生成 Kafka 分区键.有关替换表达式的更多信息，请参阅替换表达式概述.

  11. 添加从其提取并发送到远程 Kafka 集群的消息主题订阅列表.

  12. 点击 创建并启用连接器 以完成连接器的创建.