Пару месяцев я играл с Кафкой (1.0.0) и пытался понять, как работает группа потребителей.У меня...
Вот список плагинов моего коннектора: > curl localhost:8083/connector-plugins {...
пытается соединить два Kstream, но я получаю сообщение об ошибке несоответствия типов, ниже...
Я пытаюсь получить поток данных из источника MQTT со схемой, включенной в базу данных Microsoft SQL...
Я работаю над приложением для обработки журналов с помощью Spark, и я подумал использовать Kafka...
Справочная информация: я использовал неправильный реестр схемы avro при создании темы prod, и в...
Я использую следующую раковину.Проблема в том, что он устанавливает имя индексаasticsearch так же,...
Я использую следующие jmx метрики для kafka connect.
Я использую сторонний инструмент CDC, который реплицирует данные из исходной базы данных в разделы...
Я клонировал https://github.com/confluentinc/kafka-connect-jdbc,, но у меня проблемы с пониманием,...
Я могу писать сообщения в тему Kafka, но не могу найти команду windows, чтобы получить сообщение в...
Я получаю данные JSON из файла в мой файл JavaScript. Теперь я хочу отправить эти данные из этого...
У меня есть 3 брокера (brker1, broker2 и broker3), мой менеджер kafka может подключиться к broker2,...
Я настроил своего продюсера kafka заново, следуя инструкции, упомянутой здесь: https://www
У меня развернута кафка коннект эластичного поиска. Соединение распределенное работает на слиянии 3
Я планирую использовать KSQL для потоковой обработки. У меня есть следующие требования. Как только...
Мне нужен соединитель раковины kafka, позволяющий пользователю сохранять содержимое темы в виде...
Amazon S3 можно использовать в качестве приемника в кластере Kafka. Я хочу проверить, можно ли...
Я успешно использую простой пользовательский класс Partitioner, написанный на Java, для приемника...
Когда я пытаюсь запустить Kafka connect для эластичного поискового реактора, в автономном режиме я...
Я, похоже, упускаю что-то очевидное здесь, или Kafka Connect невероятно сломан, что кажется...
Подходит ли kafka connect для случаев, когда скорость передачи сообщений очень низкая. Пример: для...
Я пытаюсь протестировать и оценить поведение Kafka JDBC Sink Connector, когда база данных не...
Я следовал по этой ссылке для настройки Cassandra Sink с Kafka Connect. В блоге мы сначала...
Когда Debezium работает в качестве источника в kafka connect, и если какое-то время не происходит...