Я пытаюсь отправить некоторые данные (после присоединения KStream к KTable) в выходную тему "...

Я новичок в Kafka и ищу руководство по использованию Kafka для реализации следующего шаблона...

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

Я обнаружил сайт, демонстрирующий возможность использования API-интерфейса Kafka Consumer для...

Мы работаем с Кафкой уже около года.Около месяца назад мы столкнулись с проблемой, когда один из...

Я создаю приложение для распространения событий, которое распространяется в трех местах AWS

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

Я использую Dockerized Kafka и написал одну потребительскую программу Kafka.Он отлично работает,...

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

Я использую Kafka (kafka-python) версии 3.0.0-1.3.0.0.p0.40.Мне нужно настроить потребителя для...

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

Простой вопрос: Предположим, у меня есть тема с 3 разделами: Тема: StateEvents P1, P2 и P3. Давайте...

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

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

нам нужно создать компактные темы, которые должны быть уплотнены после определенного размера...

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

У меня есть скрипт, который потребляет сообщения kafka, а затем вызывает функцию kyotocabinet для...

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

Запрос на выборку такой же. maxWait: 100ms minBytes: 1 fetchSize: 1048576 Когда я использую с...

У меня 3 потребителя подписались на тему Кафки. Производитель публикует 1 сообщение в теме. Как я...

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

Я работаю над сохранением статуса потребителя в ребалансе Кафки.Я обнаружил, что псевдокод в...

Я хочу использовать SSL-шифрование и аутентификацию, но у нас много клиентов, и мы не хотим...

Я возился с паузой / возобновлением работы.Одна проблема, с которой я столкнулся, возникла для...

Я использую spring-kafka 1.1.3.RELEASE и kafka-clients 0.10.0.0, и я хочу установить...