У меня есть тема Kafka, из которой мне нужно читать данные JSON с помощью потребителя, но на основе...
Для требования мы собираем следующую линию данных. IBM MQ (Источник) -> Kafka Connect -> Потоковый...
Есть ли способ указать коннектору кафки, какие действия на монго следует учитывать.На самом деле, я...
Я работаю над дизайном MySQL -> Debezium -> Kafka -> Flink -> Kafka -> Kafka Connect JDBC -> MySQL
У меня есть разъем источника и приемника Kafka Connect для помещения данных в Kafka и их извлечения
В настоящее время я работаю над интеграцией: источника коннектора Debezium MySQL (v0.9.0F), Kafka...
Я планирую собрать следующий конвейер данных для одного из требований. IBM MQ -> Kafka Connect ->...
Я полностью приседаю на Kafka суше. Если я запускаю команду /cfintools/confluent-4.0
У меня есть исходный соединитель, написанный на Java, работает в распределенном режиме с offset
Поддерживает ли разъем приемника kafka jdbc запись того, что он потребляет, в другую тему.Я ищу...
Поскольку обновление дебезиевого разъема невозможно [DBZ-175] , я пытаюсь создать несколько...
Я использую Kafka Connect в Confluent Community Platform для синхронизации баз данных MySQL
Я использую kafka-connect-elasticsearch с пользовательским конвертером, который расширяет стандарт...
Похоже, что AWS Kinesis Firehose - это способ ввода данных (буферизованных вместе) в объект, есть...
Я искал поддержку соединителя kafka-connect-hdfs (Confluent) для сохранения массива байтов и...
Я создаю пользовательский коннектор kafka для чтения файлов каталога и помещаю записи в тему kafka
Я использую стоковый поисковый коннектор kafka-коннектора для индексации сообщений из нескольких...
У меня есть кластер Kafka Connect с несколькими разъемами, скажем, C1 и C2, и у меня есть рабочий,...
Я пытаюсь использовать SpoolDirCsvSourceConnector из https://github
Я пытаюсь создать соединитель Kafka-connect для передачи из темы AVRO в файл. И затем восстановите...
Я хочу подключиться к экземпляру mongoDB через ssh в моем Debezium. Для подключения к mongoDB не...
Я новичок в Kafka и потоках архитектуры данных, и у меня есть вопрос относительно дизайна тем и...
В настоящее время у меня есть кластер подключения Kafka с двумя узлами, использующими одинаковые...
Я использую Spring KafKa, и я устанавливаю ackMode в MANUAL_IMMEDIATE props