Я написал похожий обработчик, вдохновленный: https://medium

Подробности: Я пытаюсь запустить wurstmeister / kafka и wurstmeister / zookeeper изображение с...

У меня есть 2 подхода: Подход № 1 Kafka --> Spark Stream (processing data) --> Kafka -(Kafka...

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

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

Как найти время, необходимое для загрузки базы данных mysql в тему kafka при использовании формата...

Выяснилось, что существует проблема с клиентом kafka на стороне производителя (https://issues

Я активировал WSL на своем компьютере с Windows 10 и установил Ubuntu.Сейчас я пытаюсь запустить...

Я собираюсь реализовать чат-комнату, используя Spring boot и webSocket, а также Kafka, но мне нужно...

У меня есть устаревшая база данных, в которой столбец первичного ключа является строкой (да, я...

используя debezium-mongodb-connector, мне удалось перенести мои коллекции на kafka, единственная...

Есть ли тема, которую публикует соединитель Kafka Connect S3 после закрытия файла, записанного в s3

Вчера я обнаружил в журнале, что кафка повторно принимал некоторые сообщения после того, как...

У меня есть миллионы устройств IOT. каждое устройство отправляет свои данные на мой сервер. моя...

Я использую версию Kafka 2.12.При попытке запустить сервер kafka я получаю следующее исключение /...

В нашем приложении kafka-streams есть пунктуатор настенных часов, который каждые несколько секунд...

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

У меня есть приложение для распространения, которое состоит из нескольких сервисов Go. Некоторые из...

У меня есть потребитель Java, который постоянно работает с большим количеством данных и сообщений .

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

Я хочу перечислить все конфигурации, активные на брокере kafka.Я мог видеть конфигурации в файлах...

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

Я запустил Apache Kafka и Prometheus с помощью докера. Я прикреплю docker-compose и другие...

Использование kafka версии 1.1.0 на сервере и такая же зависимость Spring в клиенте производителя:...

Используя пружинную интеграцию Kafka dsl, мне интересно, почему слушатель не получает сообщения?Но...