Как связать Ksql с потоком событий ibm-cloud? - PullRequest
Новая
       2

Как связать Ksql с потоком событий ibm-cloud?

0 голосов
/ 20 февраля 2019

мы создали проект с функциями ibm и потоками событий в IBM Cloud.

Теперь я пытаюсь подключить KSQL к облачному потоку событий IBM и следую по Документу * 1004.* для получения основных идей интеграции.

Следуя инструкциям, я создал файл с именем ksql-server.properties и изменил bootstrap.servers, username, password в соответствии с моими полномочиями.Затем я запустил ksql http://localhost:8088 --config-file ksql-server.properties с локальным клиентом ksql.Я предполагаю, что все работает правильно до сих пор, так как ksql> отображается в начале каждой новой строки ...

Затем я решил проверить, связан ли ksql с моим облаком ibm, выполнив 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.`

Кто-нибудь делал это раньше или хотел бы помочь мне?Большое спасибо !!!

1 Ответ

0 голосов
/ 20 февраля 2019

Документ IBM очень устарел.KSQL работает как клиент / сервер.Сервер должен быть запущен с подробной информацией о брокере, а затем вы можете подключиться к нему с помощью клиента, включая CLI, REST API или веб-интерфейс, предоставляемый Confluent Control Center.

Итак, вам нужно запустить сервер KSQL, используя файл свойств: 

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

, а затем подключиться к нему с помощью CLI (например): 

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

См. https://docs.confluent.io/current/ksql/docs/installation/installing.html для получения дополнительной информации.

...