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

У меня есть тема кафки, которая получает события с: {timestamp, word, channel_id}. Мне нужно...

Модель пружинной интеграции kafka значительно изменилась, так как она была переработана и упрощена,...

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

У меня есть два кластера Кафки, один в Лондоне и другой в Нью-Йорке. У каждого есть три экземпляра...

У меня был td-agent, без проблем отправляющий сообщения в очередь Kafka.Но теперь я получаю...

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

Я использую Thrift только для выполнения сериализации и десериализации для повышения...

Я пытаюсь отправить сообщения Кафке с транзакцией. Итак, я использую этот код: try...

Я новичок в Apache Kafka. Я должен синхронизировать наших студентов и их регистрации. Всякий раз,...

Я хочу, чтобы событие обрабатывалось несколькими типами служб, такими как ServiceTypeA,...

Что такое операции кластера в kafka и какие все операции можно разрешить / запретить, указав...

Kafka Client: 0.11.0.0-cp1 Кафка Брокер: При перезапуске брокера Kafka наше приложение потеряло...

Локально запустил kafka , и я написал пример Производитель Spring-boot .Когда я запускаю это...

Я клонировал репозиторий Landoop Fast-Data-Dev Docker из этого репозитория GitHub . и построил...

Я пытаюсь понять, кто на Hyperledger с согласованным протоколом Kafka сгенерировал новый блок,...

Я использую docker для запуска производителя kafka с командой kafka-console-producer.sh --topic...

Есть ли способ заставить потребителя прочитать последнюю версию?Например, допустим, у меня есть...

Допустим, у меня есть два потребителя - С1 и С2 в одной группе потребителей. Есть 10 сообщений на...

Если у меня есть глобальная конфигурация с экземплярами EMEA, APAC и NYC для конкретного приложения...

Генератор сообщений, использующий привязки Кафки из облачных потоков Spring @Component public...

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

Потребитель должен стать каким-либо производителем для определенного раздела в теме...

У меня есть обработчик kafka в весенней загрузке: @KafkaListener(topics = "topic-one",...

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