Я пытаюсь использовать mirror maker для репликации темы __consumre_offsets вместе с другими темами....

У меня есть confluent-ksql-сервер, работающий на одном из узлов моего кластера.Можем ли мы...

У меня есть много тем, созданных без ключа, как я могу изменить их и добавить нужную? Мне нужно...

При публикации нового исходного соединителя с использованием Confluent: curl -X POST -H "Тип...

Я пытаюсь запустить clean кластера Kafka в докере, используя дистрибутив Confluent Kafka 5.0.0. Увы...

При локальной настройке клиента Kafka на моем Mac без указания ssl.ca.location все работает.Но...

Confluent Kafka 5.0.0 был установлен на AWS EC2 с публичным IP, скажем, 54.XX.XX.XX Открыт порт...

Мы переносим наше приложение из Apache Kafka на платформу Confluent. Версия Apache Kafka: 1.1.0...

Я попробовал следующее - ./confluent start, что дает - Этот CLI предназначен только для разработки,...

Мы используем коннектор Confluent MS SQL CDC, а дескриптор соединения: curl -X POST -H \...

Я передаю длинную строку JSON String в тему kafka, например: { "glossary": {...

Здесь мой KSQL, используя WINDOW TUMBLING предложение: SELECT sale_date, region, SUM(total) FROM...

Есть ли в Kafka процедура для резервного копирования данных брокера Kafka? Как работает резервное...

Я использовал для установки автономного Confluent Сервер со встроенным Zookeeper (ZK).Но теперь мой...

Я новичок в Kafka иasticSearch, я хочу перенести данные Elasticsearch в тему kafka, с соединителем...

Пожалуйста, найдите нижеприведенную проблему и подтвердите ее. Шаг-01: На основе условия соединения...

У меня установлены разъемы источника и приемника с использованием слияния, и они работают нормально

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

Мы обновились с Confluent 4.0.0 до 5.0.0, после обновления мы не можем перечислить задержку...

У меня есть тема кафки, и каждое сообщение в теме имеет широту / долготу и метку времени события....

Я пишу авро сообщения в тему кафки, используя схему реестра.Затем создан поток на основе темы.Крик,...

Я пытаюсь настроить Confluent-4.1.1 в Ubuntu 16.04. Чтобы запустить сервер ZooKeeper, я запустил

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

Я использую спарк для получения данных из темы кафка. Я должен deserialaizer avro данных с...

Я не могу добавить слияния репо в мой сб. Я посмотрел пример pom и нашел определение добавления...