Как установить group.id в приложении KSQL

Мне нужно установить свойство group.id в моем приложении KSQL.

Я знаю, что это возможно в приложении Kafka Stream с помощью свойства application.id, но это не работает для KSQL.


apache-kafka confluent-platform ksqldb
person Marco Catalano    schedule 26.06.2019    source источник

Ответы (1)


arrow_upward
1
arrow_downward

Я думаю, вы ищете ksql.service.id. Ссылка: https://docs.confluent.io/current/ksql/docs/faq.html#how-do-i-add-ksql-servers-to-an-existing-ksql-cluster

person Robin Moffatt    schedule 26.06.2019
comment
Из документации я обнаружил, что если несколько серверов KSQL подключаются к одному кластеру Kafka (т.е. к одним и тем же bootstrap.servers) и имеют одинаковый ksql.service.id, они образуют кластер KSQL и разделяют рабочую нагрузку, но мне нужно настроить потребителя ID группы для одиночного непрерывного запроса KSQL. - person Marco Catalano; 28.06.2019
comment
Вариант использования: 1) запустить запрос 2) завершить и отбросить запрос 3) перезапустить тот же запрос (мне нужно перезапустить с последнего зафиксированного смещения, а не с самого раннего / последнего) - person Marco Catalano; 28.06.2019
comment
В настоящее время это невозможно с KSQL. - person Robin Moffatt; 04.07.2019
comment
@RobinMoffatt Есть ли эта функция в дорожной карте KSQL? Восстановление запроса из последнего зафиксированного смещения кажется довольно распространенным вариантом использования. - person Lucas Cardozo; 04.03.2020
comment
@RobinMoffatt, возможен ли теперь такой вариант использования с ksql? - person iamabhaykmr; 28.01.2021