Я пытаюсь выполнить CDC с помощью debezium protobuf из Postgres 9.6, и в соответствии с инструкцией...

Поведение приложения моих потоков не такое, как ожидалось: У меня есть один потребитель и один...

Я использую kafka 2.0 с kafka connect, работающим в распределенном режиме, и попытался настроить...

Мне нужна помощь с настройкой.У меня есть 3 отдельных проекта, которые должны общаться через Spring...

Я читаю текстовые файлы и хочу записать данные с flume в тему kafka и hdfs. Вы можете увидеть мою...

Я хочу заменить свою работу cron на apache kafka, используя php. Возможно ли это? Теперь мой cron...

Я использовал RDKAFKA в php для параллельной работы потребителя. Но первый потребитель принял все...

У меня есть простой код для подключения к Kafka через Kerberos. ‍ index.php: <?php require...

Я создал класс, который реализует org.apache.kafka.common.metrics.KafkaMetric примерно так: public...

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

Я хочу сделать простой запрос в Flink SQL в одной таблице, которая включает оператор group by. Но в...

Как использовать потоковую обработку spark strcutured для пакетных запросов, как мне прочитать...

У меня есть сервер kafka, работающий на сервере linux 10.xx.xx.xx: 9092. И у меня есть...

Я столкнулся с проблемой, из-за которой я не получаю результаты из своего запроса в Flink-SQL. У...

Я создаю приложение Stream Streaming, читаю входное сообщение из темы kafka, сообщение...

Как KafkaStream потребляет сообщения из темы. Ниже мой код: Properties props = new Properties();...

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

Я пытаюсь отобразить файл CSV, уже использованный Flink и созданный Kafka, в Tuple4. Мой CSV-файл...

Я использую приложение Kafka Streams с тремя под-топологиями. Этапы деятельности примерно таковы:...

Из-за потребностей бизнеса мне нужно использовать druid, но druid не может загружать в него данные...

Я следую учебнику @RobinMoffat "Simplest Useful .." для Kafka Connect и пытаюсь подключиться к моей...

Мы используем Kafka Streams для потребления, обработки и производства сообщений, а в PROD env мы...

получение приведенной ниже трассировки стека ошибок при работе с потоками kafka ОБНОВЛЕНИЕ:...

<?php $rk = new RdKafka\Consumer(); $rk->setLogLevel(LOG_DEBUG); $rk->addBrokers("10

У меня есть несколько динамических потребителей Kafka (на основе идентификатора отдела и т. Д.), И...