Скажем, есть группа потребителей.(Потребители с одинаковым идентификатором группы). Группа...

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

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

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

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

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

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

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

Насколько я понимаю, разделы и потребители связаны соотношением 1: 1, в котором один пользователь...

Существует ли какая-либо опция или конфигурация, которая облегчит одному потребителю Kafka...

Я новичок в Kafka и пытаюсь создать библиотеку-обертку на Java и Go (использует Confluent /...

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

Мне нужно получать последнее смещение для всех разделов темы каждые N секунд (для целей...

У меня проблема с потребителем kafka в python, вот мой пример использования. Производитель kafka...

В старых пользовательских конфигах есть параметр: rebalance.max.retries: Когда новый потребитель...

Как обрабатывать большие сообщения в Kafka, такие как более 20 МБ и т. Д. [2019-03-13 08: 59: 10...

Когда идентификатор клиента явно не установлен клиентским приложением kafka, как именно создается...

Например, если у меня есть длительный процесс в одном из моих KafkaConsumer.(Допустим, для...

Я пытаюсь перенести данные кафки в HDFS.Я вижу данные темы kafka в окне kafka-consumer-console. Вот...

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

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

Использование Kafka / Java со следующей конфигурацией props.put(ConsumerConfig

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

Какое рекомендуемое количество потребителей на группу в Кафке? По сути, у меня есть 400 тем,...

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