Я пытаюсь построить конвейер CDC, используя: DB2 - IBM CDC --Kafka и я пытаюсь найти правильный...

У меня есть приложение Streams с GlobalKtable, поддерживаемым RocksDB, которое не работает

Я хочу создать простое приложение, основанное на данных датчика, с Apache Kafka. Мой вопрос очень...

Я использую kafka connect 1.0.0 с kafka версии 1.0 для моего kafka-cassandra-sink. Создала тестовую...

Я понимаю, что темы неизменны. Допустим, ваша тема в плохом состоянии. Неупорядоченные участки...

Я просто отчаянно ищу пример кода для адаптера Esper CEP Kafka. Я уже установил Kafka и записал...

Я использую kafka 2.12-2.2.0.0 с kafka-connect-cassandra-1.1.0-1.1.0 -all и apache cassandra 3.0.8...

Я пытаюсь присоединиться к KStream: создан из темы, тема имеет значение JSON. Я повторно набираю...

У меня есть бизнес-требование, где мне нужно 12-часовое оконное управление, и нужно запросить...

Можно ли создать несколько независимых кластеров в распределенной среде и управлять ими через центр...

У меня есть потоковое приложение kafka, которое использует KTable.Мое приложение работало некоторое...

Я хочу выполнить какое-то действие, если мой код получит org.apache.kafka.clients.consumer

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

Я застрял в проблеме, когда моя kafka работает на другом экземпляре, а мое приложение на другом...

Я развернул kafka в kubernetes, используя https://github.com/Yolean/kubernetes-kafka. Но, потребляя...

Я столкнулся с проблемой, аналогичной той, которая упоминается в приведенном ниже URL-адресе....

Я пытался установить соединение между Kafka producer, работающим на другом сервере, и Consumer на...

У меня есть логи, приходящие в 1 тему Kafka, я их анализирую и помещаю в 2 отдельные темы Kafka (по...

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

Я получаю сообщения от брокера mqtt по теме kafka, используя соединитель kafka-mqtt. Затем я...

У меня есть приложение Kafka Streams. У меня не было проблем с rocksdb или Kafka Streams, пока мы...

Я не знаю преимуществ API Kafka REST Proxy. Это REST API, поэтому я знаю, что это удобно для...

У меня есть сообщение, которое генерируется на стороне сервера. В соответствии с flask-socketio doc...

Я пытаюсь написать загрузочные приложения Spring для потребителя Reactive Kafka, используя...

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