Я использую Spring Boot для отправки данных из одного приложения в другое с помощью Kafka. Мой...

У меня был этот старый стек kafka в производстве с ubuntu 14 на версии 0.10.1.0 kafka ,, я только...

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

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

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

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

Знаете ли вы какую-либо команду для удаления всех доступных ACL из Kafka?Если вы добавили буквенные...

Я пытаюсь транслировать журналы своего приложения на kafka с помощью приложения Log4J. Я вижу, как...

На основе этого примера мы создали следующий файл docker-compose, docker-compose.yaml: version:...

Я использую схему Avro для записи данных в тему Кафки.Изначально все работало нормально.После...

kafka версия: 0.9.0.1 Если n = 20, я должен получить последние 20 сообщений по теме. сейчас я...

В первый момент мне пришлось обработать информацию из текстового файла: C1-4-, C2_4, С1 ______ 10...

Я не уверен, что этот вопрос где-то уже адресован, но я не смог найти полезного ответа в Интернете....

У меня есть приложение для регистрации транзакций в таблицах hbase. Я использую сообщения...

У меня есть требование отправлять данные из внешней системы в тему Kafka с единовременной...

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

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

У меня есть задание Flink, которое читает из Kafka (v0.9) и пишет в Redis. Я хочу отслеживать...

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

У меня много микросервисов для чтения / записи сообщений Avro в Кафке. Схемы отличные. Авро отлично

В настоящее время мы рассматриваем возможность инвестирования в компанию Kafka-as-service (Paas) в...

Я использую Spring Boot Starter версии 2.0.8.RELEASE и пытаюсь выполнить обновление до: 2.1.4

У меня есть файл размером 493 мегабайта, который я хочу отправить для отправки журналов от...

Я пытаюсь раскрутить серверы zookeeper и kafka из моего кода Java. Обычно мы запускаем пакетные...

Представьте, что у меня есть кластер из трех узлов kafka, в котором есть 1000 тем с одним разделом....