Результаты поиска по запросу "ksql"
Основываясь на моем анализе: несколько объединений в одном операторе в настоящее время не поддерживаются. Вы можете сделать то же самое, написав несколько операторов KSQL: CREATE STREAM промежуточный AS SELECT * FROM ammas cd LEFT JOIN appat ab ON ab.id = cd.id SELECT * FROM промежуточный cd LEFT JOIN annat aa ON aa.id = cd.id
: describe ammas; Field | Type ------------------------------------- ROWTIME | BIGINT (system) ROWKEY | VARCHAR(STRING) (system) ID | INTEGER -------------------------------------Для получения статистики времени выполнения и деталей запроса ...
2. KSQL должен извлекать последнюю версию схемы при создании нового потока по теме, да.
ользую Confluent JDBC Kafka для публикации сообщений в теме. Исходный соединитель будет отправлять данные в тему вместе со схемой в каждом опросе. Я хочу получить эту схему. Является ли это возможным? Как? Может кто-нибудь предложить мне Я ...
Спасибо, @robin за ответ на этот вопрос. Это было блокирующим для нас. Я ценю ваше время и усилия, чтобы предоставить решение. Решение работает. Еще раз спасибо :)
: Запустите производителя для создания образца данных ./bin/kafka-avro-console-producer \ --broker-list localhost:9092 --topic stream-test-topic \ --property schema.registry.url=http://localhost:8081 ...