Я использую образ Kafka Connect Docker и могу успешно установить пользовательский плагин...
Я установил Docker на мою Windows 10, а также установил Kafka. Я создал тему " test " внутри...
Можно ли настроить Kafka Connect (Source) для генерации надгробной записи? У меня есть таблица...
Я настроил кластер MSK в aws и создал экземпляр EC2 в том же vpn. Я попробовал...
[2019-10-22 13: 36: 41,286] ОШИБКА Остановка после ошибки соединителя (org.apache.kafka.connect.cli
Я не использую слияние, я могу запустить Zookeeper и Kafka успешно. И следуя инструкциям...
Можно ли написать диалект, который будет возвращать другой запрос в зависимости от значения...
Я создаю производителя тем kafka со следующими конфигурациями acks - all max.in.flight.requests.per
Я пытаюсь отправить запись для каждой строки 7 дней. Это конфигурация, над которой я работал, но...
Я пытаюсь скопировать содержимое одной темы test1 в другую тему test1_connect Содержимое - это...
Я пытаюсь написать собственный исходный соединитель для kafka connect, и мне требуется написать в...
Я использовал соединитель источника kafka для передачи документов из Couchbase в kafka. Эти...
Я настраиваю производителя, который отправляет сообщения в виде (значения ключа) [key - это...
Я получил ошибку Не удалось создать экземпляр класса Partitioner при попытке создать исходный...
У меня запущена настройка Kafka с соединителем Elasticsearch, и я успешно индексирую новые...
Я пытаюсь записать файл коннектора Sink, который будет использовать тематические сообщения, и...
Мы используем kafka connect в HDP 2.6.4, сливной соединитель и реестр схем hortonwork. kafka...
В моем mongodb есть эти данные mongo01:PRIMARY> db.col.find({"_id" :...
Существуют предопределенные SMT Kafka Connect, которые работают в цепочках, но есть ли способ...
Привет после просмотра https://docs.confluent
Мне трудно реализовать функцию, в которой я могу иметь динамическое значение сообщения для Кафки. Я...
Я работаю с Kafka Connect (используя реализацию Confluent) и наблюдаю странное поведение. Я...
Я делаю POC из Confluent Kafka Connect версии 5.2.3. Мы пытаемся скопировать сообщение темы из...
Сейчас я выполняю нагрузочный тест на разъеме Debezium postgres, чтобы узнать, может ли он...
Вот метод переопределения для обработки записей: @Override public void...