Результаты поиска по запросу "apache-kafka-connect"
Спасибо, Рэндалл ... Это очень помогло ..
лкиваюсь с вопросом ниже об изменении некоторых свойств, связанных с kafka и перезапуске кластера.
Что вы спасете мой день, удивительный ответ, можем ли мы установить customer.auto.offset.reset = как можно раньше для потребителя в kafka connect?
перезапуска задачи-приемника Kafka Connect S3 он возобновил запись с самого начала темы и записал дубликаты старых записей. Другими словами, Kafka Connect, казалось, потерял свое место. Итак, я представляю, что Kafka Connect хранит информацию о ...
Поскольку данные поступают не только из одного источника Oracle, существует несколько источников Oracle, которые вставляются в несколько тем.
аюсь использовать соединитель приемника JDBC Kafka Connect для вставки данных в Oracle, но выдает ошибку. Я попытался со всеми возможными конфигурациями схемы. Ниже приведены примеры. Пожалуйста, предложите, если я что-то упустил ниже, мои файлы ...
список источников. Большое спасибо !
ользую изображение Confluent Kafka Docker, в частности, с помощью этого: https://github.com/confluentinc/cp-docker-images/tree/4.0.x/examples/cp-all-in-one [https://github.com/confluentinc/cp-docker-images/tree/4.0.x/examples/cp-all-in-one] Я ...
позволяет обогатить первичный ключ, который может быть полезен при наличии событий из нескольких таблиц в одной теме. На вопрос в комментарии выше, его первоначальный вариант использования был для сегментированных таблиц, но он должен работать и для таблиц с разными схемами.
челhttp://debezium.io/docs/connectors/mysql/ [http://debezium.io/docs/connectors/mysql/]но я не смог найти никакой информации о том, можно ли настроить debezium так, чтобы изменения из 2 (или более) таблиц могли быть записаны в одну и ту же тему ...
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 ...