这篇博文是关于如何通过sapcloudconnector将apachekafka连接到sapcloud平台，并将其用于订阅和/或发布目的。最初这是一个研究项目的一部分，因此本指南并不保证企业准备就绪。

让ApacheKafka连接到CloudFoundry上的NodeJS应用程序的最大困难是Kafka直接通过TCP使用二进制协议(https://kafka.apache.org/protocol.html). 这意味着您的连接必须在TCP级别而不是HTTP级别。因此，大数据是啥意思，我们无法在CF上使用SAP Cloud Platform Destination Service，并且到Apache Kafka的TCP连接需要高级SOCKS5实现来访问连接代理。

开始之前需要什么：

Apache Kafka安装在您的内部部署环境中（快速启动）SAP Cloud Platform Cloud Foundry帐户，包括分配的空间。您必须是管理员才能稍后连接到云连接器。否则，当您尝试连接

您将需要云铸造的哪些服务：

连接服务时，您将得到HTTP 417授权和信任管理服务（xsuaa）

在开始安装SAP Cloud Connector之前，请确保您知道这是一个安全关键型安装。您可能需要从服务器或虚拟机打开到外部的端口。

关于如何安装SAP Cloud Connector的指南可以在这里找到。有关如何配置SAP Cloud Connector以与您的SAP Cloud Platform帐户配合使用的指南，请参见此处。

注意：在我的设置中，我没有使用任何位置ID，数据与大数据专业，因为这是唯一连接到SCP帐户的云连接器。但是，如果您需要位置ID，请稍后在代码示例中修改SOCKS5的身份验证请求。

一旦在您的服务器和您的SCP帐户之间建立了连接，您可以按照此处所述设置云到本地映射。我曾作为内部主机本地主机：9092（9092是Kafka运行的标准端口–不要将其与Apache Zookeeper使用的端口混淆）并作为虚拟主机"卡夫卡。云：9092". 当您检查可用性时，SAP Cloud Connector将返回"Reachable"。您也可以在您的SAP云平台驾驶舱的Cloud Connectors下找到这个映射。由于这是一个TCP连接，因此它没有显示任何资源，并且您不能添加任何路径映射，这是正确的。

下一步将要求您在此处创建一个连接和UAA的服务实例–文档。UAA需要为连接代理获取JWT令牌。这两个服务都需要绑定到您的节点.js应用程序。

有一个很好的指南，告诉你如何做到这一点，以及你需要在你的应用程序中编写什么代码节点.js应用程序：https://blogs.sap.com/2019/04/02/a-do-it-yourself-at-home-guide-how-to-connect-a-node.js-app-on-sap-cloud-platform-for-the-cloud-foundry-to-an-s4hana-on-premise-system-security-via-cloud-connector/

现在最关键的部分需要解决。通过连接代理与卡夫卡的连接。这里有一个SAP帮助文档，大数据是干什么的，说明如何处理TCP连接（Java中的代码示例），您可以在这里找到。

关键是要理解，您需要一个特殊的高级SOCKS5实现才能接触到Kafka。在发表这篇博文时，还没有节点包能够处理SOCKS5和通过JWT令牌的身份验证。但是，淘客返利app，节点包socksv5有一种可扩展性的概念，我使用了这个概念（我没有使用原始包，因为它会导致一些错误）。

下面的代码示例是为了简化硬编码的URL。

这个代码片段主要用于建立到连接代理的连接。SOCKS5协议基于简单的步骤：

客户机和服务器的问候语客户端提供身份验证选项服务器选择身份验证选项客户端发送身份验证请求服务器验证身份验证请求客户端请求连接服务器建立连接

非斜体标记的步骤包含在节点包中。但是，连接代理请求0x80（由协议定义为自定义身份验证保留）身份验证选项，该选项请求斜体标记步骤的自定义实现。请注意，买服务器云，使用big endian（Be）处理整数！

以下代码段使用kafkajs作为Kafka NodeJS处理程序。除了需要使用代理请求的套接字之外，它使用了很多标准功能。我希望本教程，特别是自定义实现（包括SOCKS5的身份验证过程的代码片段）对您有所帮助。如果您决定在您的内部部署世界中使用Kafka，那么目前没有其他选项可以实现一个经过调整的SOCKS5版本来连接到Connectivity Proxy。当这对你有用时，留下一个喜欢或评论。