如何将 Ksql 与 ibm-cloud 事件流连接?

How to connect Ksql with ibm-cloud event-stream?

我们在 IBM Cloud 中使用 ibm 函数和事件流创建了一个项目。

现在,我正在尝试将 KSQL 与 IBM 云事件流连接起来,并且我正在关注 Document 以获得集成的基本思想。

按照说明,我创建了一个名为 ksql-server.properties 的文件,并根据我的凭据修改了 bootstrap.serversusernamepassword。然后我 运行 ksql http://localhost:8088 --config-file ksql-server.properties 使用 ksql 本地 cli。由于 ksql> 显示在每个新行的前面,所以我认为到目前为止一切都正确运行...

然后我决定通过 运行 SHOW topics;

检查 ksql 是否与我的 ibm 云连接

结果是一些错误行:

    `Error issuing POST to KSQL server. path:ksql'`
    `Caused by: com.fasterxml.jackson.databind.JsonMappingException: Failed to set 'ssl.protocol' to 'TLSv1.2' (through reference chain: io.confluent.ksql.rest.entity.KsqlRequest["streamsProperties"])`
    `Caused by: Failed to set 'ssl.protocol' to 'TLSv1.2' (through reference chain: io.confluent.ksql.rest.entity.KsqlRequest["streamsProperties"])
    `
    `Caused by: Failed to set 'ssl.protocol' to 'TLSv1.2'`
    `Caused by: Cannot override property 'ssl.protocol'`

此外,当它告诉我要执行以下操作时,我很快就迷失在第 4 步: `然后启动DataGen两次如下:

    i. With bootstrap-server=HOSTNAME:PORTNUMBER quickstart=users format=json topic=users maxInterval=10000 to start creating users events.

    ii. With bootstrap-server=HOSTNAME:PORTNUMBER quickstart=pageviews format=delimited topic=pageviews maxInterval=10000 to start creating pageviews events.`

有没有人以前做过这个或者愿意帮助我?非常感谢!!!

IBM 文档非常过时。 KSQL 运行s 作为 client/server。服务器需要 运行 包含代理的详细信息,然后您可以使用客户端连接到它,包括 CLI、REST API 或 Confluent Control Center 提供的 Web 界面。

因此您需要运行 KSQL 服务器使用您的属性文件:

./bin/ksql-server-start ksql-server.properties

然后使用 CLI 连接到它(例如):

./bin/ksql http://localhost:8088

有关详细信息,请参阅 https://docs.confluent.io/current/ksql/docs/installation/installing.html