Я использую образ 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...