Можно ли в KSQL передавать старые и новые значения из таблицы? Мы хотели бы использовать таблицу в качестве хранилища значений, и при изменении потока выводится значение "разворота", которое является предыдущим, каким-то образом помечено тегами, и...

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

У меня есть задание Kafka-Connect, настроенное на периодический запрос таблицы MySQL и размещение сообщений в очереди. Структура этих сообщений определяется с помощью схемы Avro. У меня проблема с отображением для одного из моих столбцов. Столбец...

У меня есть тема "Клиенты", и я создал для нее ленту. CREATE STREAM customers_stream (customerId INT, isActive BOOLEAN) WITH (KAFKA_TOPIC='customers', VALUE_FORMAT='json'); Мой продюсер для темы customers генерирует целочисленный ключ и...

Я пытаюсь подключиться к внешней базе данных Oracle, используя ksqlDB, работающий в контейнере докеров на моем компьютере с Windows 10. Я просмотрел руководства, упомянутые на веб-сайте ksqlDB, и мне удалось запустить ksqlDB, используя приведенный...

У меня есть существующий ksqldb-сервер, который я хочу обновить с v0.6.0 с подключением как отдельный узел до v0.8.1 со встроенным подключением. Однако ksqldb-server аварийно завершает работу после запуска со следующим журналом: ksqldb-server...

У меня есть тема, по которой я отправляю json в следующем формате: { "schema": { "type": "string", "optional": true }, "payload": “CustomerData{version='1', customerId=‘76813432’,...

Как я могу использовать полный api клиента ksqldb с gradle? Почему есть 2 разных пакета? repositories { mavenCentral() jcenter() maven { url "https://packages.confluent.io/maven/" } } dependencies {...

Я выполняю агрегирование с KSQL, и мне нужно сохранить выходную таблицу в MariaDB. Я уже настроил MariaDB и JdbcSinkConnector. К сожалению, раковина мне просто не подойдет. Это структура таблицы в KSQL, которую я хотел бы сбросить в MariaDB:...