Я пытаюсь использовать TimeBasedPartitioner, который извлекает, используя RecordField со следующей...

Кажется, что невозможно использовать RegexRoute, чтобы заменить все точки в названии темы...

Используя преобразования одиночного сообщения (SMT), например, InsertField Transformation, можно...

Соединитель Kafka запускается нормально и читает поток данных в теме, однако он не записывает...

Почему слитый репликатор реплицирует уже использованные сообщения? Существует много вариантов...

У нас работает коннектор приемника kafka hdfs (версия 5.2.1), и необходимо, чтобы данные HDFS были...

Я использую коннектор JDBC kafka для переноса данных из оракула в темы кафки. У меня есть названия...

Я использовал драйвер мойки jdbc от kafka connect. это позволяет создать таблицу с одним первичным...

Я использовал исходный соединитель JDBC для передачи данных из тем оракула в кафку.У меня есть темы...

Мы используем Confluent's Kafka S3 Connector , версия 5.2.1.Работая с одним узлом в настройке...

Я пытаюсь использовать возрастающую загрузку, чтобы создать сообщение для темы об обновлении...

Как часть требования, мы продолжаем использовать Kafka connect для передачи данных в нашу базу...

У меня есть данные в теме Kafka, которые я хочу сохранить на своем озере данных. Прежде чем...

У меня установлен вручную Confluent Kafka Connect S3 с использованием автономного метода, а не с...

Я читаю данные с машины и транслирую их как JSON в тему кафки. Я хотел бы прочитать эту тему и...

Моя конфигурация: Confluent (5.0.0) Kafka выдает несколько авро-сообщений. Рабочий Connect...

Мне нужно получить данные из базы данных PostgreSQL с ~ 2000 схемами. Все схемы содержат одинаковые...

Мы используем Kafka S3 Connector для конвейерного журнала, поскольку он гарантирует семантику ровно...

У меня есть конфлюентный кластер kafka , работающий внутри докер-контейнеров на машинах EC2, как...

Я пытаюсь написать интеграционный тест для моего потребителя Kafka.Я выполнил официальную...

Я пытаюсь настроить примеры потоковой передачи apache kafka отсюда: https://github

Я установил Kafka на локальный Minikube, используя диаграммы Шлема https://github

Я использую коннектор приемника JDBC и у меня плохое сообщение в теме.Я знаю, почему сообщение...

Я бы интегрировал решение для слияния kafka-rest-proxy с apache kafka 2.0.0 Может кто-нибудь...

Я боролся с проблемой использования kafka connect и приемника S3. Первая структура: { Partition:...