Результаты поиска по запросу "confluent"
2. KSQL должен извлекать последнюю версию схемы при создании нового потока по теме, да.
ользую Confluent JDBC Kafka для публикации сообщений в теме. Исходный соединитель будет отправлять данные в тему вместе со схемой в каждом опросе. Я хочу получить эту схему. Является ли это возможным? Как? Может кто-нибудь предложить мне Я ...
Изменения, как показано ниже:
lastic Search Connector выбрасывается следующее исключение: [2018-05-07 11:40:38,975] ERROR WorkerSinkTask{id=elasticsearch-sink-0} Task threw an uncaught and unrecoverable ...
Основываясь на моем анализе: несколько объединений в одном операторе в настоящее время не поддерживаются. Вы можете сделать то же самое, написав несколько операторов 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 -------------------------------------Для получения статистики времени выполнения и деталей запроса ...
Что вы спасете мой день, удивительный ответ, можем ли мы установить customer.auto.offset.reset = как можно раньше для потребителя в kafka connect?
перезапуска задачи-приемника Kafka Connect S3 он возобновил запись с самого начала темы и записал дубликаты старых записей. Другими словами, Kafka Connect, казалось, потерял свое место. Итак, я представляю, что Kafka Connect хранит информацию о ...