如何将 Ksql 与 ibm-cloud 事件流连接?
How to connect Ksql with ibm-cloud event-stream?
我们在 IBM Cloud 中使用 ibm 函数和事件流创建了一个项目。
现在,我正在尝试将 KSQL 与 IBM 云事件流连接起来,并且我正在关注 Document 以获得集成的基本思想。
按照说明,我创建了一个名为 ksql-server.properties
的文件,并根据我的凭据修改了 bootstrap.servers
、username
、password
。然后我 运行 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。
我们在 IBM Cloud 中使用 ibm 函数和事件流创建了一个项目。
现在,我正在尝试将 KSQL 与 IBM 云事件流连接起来,并且我正在关注 Document 以获得集成的基本思想。
按照说明,我创建了一个名为 ksql-server.properties
的文件,并根据我的凭据修改了 bootstrap.servers
、username
、password
。然后我 运行 ksql http://localhost:8088 --config-file ksql-server.properties
使用 ksql 本地 cli。由于 ksql>
显示在每个新行的前面,所以我认为到目前为止一切都正确运行...
然后我决定通过 运行 SHOW topics;
结果是一些错误行:
`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。