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

Итак, я создаю приложение на python, которое берет данные из твиттера, а затем сохраняет их на...

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

Я отключил автоматическую фиксацию и не фиксирую смещение также от потребителя после прочтения....

Мы используем версию Spring Kafka 2.1.4.RELEASE в нашем проекте, и у нас есть следующая...

Мы создаем систему для перемещения данных из одной точки в другую в нашей экосистеме с...

Наш брокер получает большое количество сообщений (около 15-30 МБ / с), и мы хотели бы принять эти...

У меня вопрос: при каких условиях потребитель кафки получит непоследовательные данные?

Возникла проблема с отставанием потребителя кафки.Теперь мы перезапускаем потребителя кафки, чтобы...

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

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

В документации kafka я пытаюсь понять это свойство max.poll.interval.ms Максимальная задержка между...

Я хотел бы знать, есть ли какая-либо опция в spring-kafka, которая будет захватывать все новые...

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

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

В моей теме только один раздел, но мне нужно добиться многократной обработки.У меня огромное...

Есть ли у нас какие-либо опции, такие как получение последних 10/20 / и т. Д. Сообщений из темы...

У меня есть потребитель Cafka C1 в группе потребителей CG1, подписанный на тему T1. Недавно я...

Я пытаюсь интегрировать Кафку с топологией Герона.Однако я не могу найти никаких примеров с...

Я использую кластер Apache Flink 1.6.0.Мы используем FlinkKafkaConsumer011 в работе.Контрольная...

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

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

Некоторые из моих потребителей Kafka (но не все) демонстрируют интересную картину, касающуюся их...

Описание Я пытался проверить правильность фрагмента данных, которые я посылаю Кафке.Когда я пытался...

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