1
ответ
Можно ли переименовать поля при запуске сообщения соединителя debezium mysql?
Я настроил коннектор debezium mysql, мне нужно включить дополнительное поле в качестве имени таблицы в полезную нагрузку. Какое изменение конфигурации мне нужно сделать, чтобы добиться этого?
вопрос задан: 27 March 2019 07:13
1
ответ
Не удается подключить Debezium 0.9.2 к SQL Server 2008 R2
Когда я пытаюсь подключить Debezium к своей базе данных SQL Server после включения функции CDC, у меня появляется следующее сообщение об ошибке: java.lang.RuntimeException: Не удалось получить имя базы данных на io.debezium ....
вопрос задан: 4 March 2019 13:08
1
ответ
Как преодолеть ошибку IllegalAccessError при запуске коннектора в Kafka
Я пишу разъем для Kafka Connect. Ошибка, которую я вижу во время запуска соединителя, является java.lang.IllegalAccessError: попытался получить доступ к полю org.apache.kafka.common.config.ConfigTransformer ....
вопрос задан: 20 January 2019 00:01
1
ответ
Kafka Connect против потоков для раковин [закрыто]
Я пытаюсь понять, что Connect покупает у вас, а Streams - нет. У нас есть часть нашего приложения, где мы хотим использовать тему и писать в mariadb. Я мог бы сделать это с помощью простого ...
вопрос задан: 19 January 2019 23:58
1
ответ
Kafka Connect не может читать темы Kafka по SSL
Запустите kafka connect в нашем docker-swarm со следующим файлом compose: cp-kafka-connect-node: образ: confluentinc / cp-kafka-connect: порты 5.1.0: - 28085: 28085 секретов: - ...
вопрос задан: 18 January 2019 16:45
1
ответ
Можем ли мы запустить коннектор Confluent JDBC Kafka в операционной системе Windows?
мы планируем установить и запустить JDBC-разъем Confluent в операционной системе Windows (без Docker и Cygwin с установленным curl). Я нашел пару постов, говорящих, нам нужно немного "предварительно ...
вопрос задан: 17 January 2019 20:41
1
ответ
Проблема с соединителем источника JDBC Confluent
Я получаю следующую проблему при попытке использовать конфлюент для kafka-connect. Я пытаюсь следовать демонстрации, приведенной на https: //www.confluent.io/blog/simplest-useful-kafka-connect-data-pipeline-world -...
вопрос задан: 17 January 2019 20:08
1
ответ
IBM MQ и Kafka Интеграция
Я работаю над решением, в котором клиент уже владеет iBM MQ, поэтому мне нужно интегрировать в него Kafka. мне нужно было бы получить данные из IBM MQ и перенести их в тему kafka для дальнейшей обработки. Я ...
вопрос задан: 17 January 2019 19:36
1
ответ
Порядок сообщений с Kafka Connect Elasticsearch Connector
У нас возникают проблемы с обеспечением порядка, в котором сообщения из темы Kafka отправляются в Elasticsearch с помощью Kafka Connect Elasticsearch Connector. В теме сообщения в праве ...
вопрос задан: 17 January 2019 10:14
1
ответ
Как реализовать kafka-connect, используя apache-kaka вместо слияния
Я хотел бы использовать версию kafka-connect с открытым исходным кодом вместо слитной, поскольку кажется, что слияния cli не для производства, а только для dev. Я хотел бы иметь возможность слушать ...
вопрос задан: 16 January 2019 21:56
1
ответ
kafka Connect: Tasks.max больше, чем количество разделов, но в статусе написано RUNNING
В нашей настройке у нас есть 50 задач и 40 разделов в теме. У нас есть 2 рабочих. В идеале, коннектор должен запускать только 40 задач, но мы видим, что все 50 задач имеют статус RUNNING. Как так ...
вопрос задан: 16 January 2019 04:04
1
ответ
Kafka Connect - Удалить коннектор с конфигами?
Я знаю, как удалить коннектор Kafka, как упомянуто здесь. Kafka Connect - Как удалить коннектор, но я не уверен, удаляет ли он также / стирает определенные конфиги, связанные с коннектором, смещения и статус из * ...
вопрос задан: 15 January 2019 19:28
0
ответов
Не удалось найти класс io.confluent.connect.avro.ConnectDefault
Я сталкиваюсь с подобной проблемой, упомянутой в https://github.com/confluentinc/kafka-streams-examples/issues/22. Я изменил свою исходную конфигурацию JDBC согласно рекомендации в комментарии, но все же ...
вопрос задан: 10 March 2019 09:10
0
ответов
Кафка испорченное сообщение
Я пытаюсь опубликовать данные в kafka, читая данные из TeradataDB с помощью Kafka-Connect JDBCSourcConnector. Сообщение при просмотре у потребителя кажется поврежденным, как показано ниже. Пожалуйста, помогите. ...
вопрос задан: 21 February 2019 21:15
0
ответов
Соединитель преобразует неправильно карты ключ раздела
У меня есть простая таблица базы данных в MySQL, которая имеет (id varchar (255), val varchar (255), ..., ...). Я настроил Kafka Connect для потоковой передачи таблицы в тему (CONNECT_TOPIC) с двадцатью разделами. Я имею ...
вопрос задан: 18 January 2019 23:38