в kafka cosummer, если обработка сообщения занимает более 5 минут, сообщение обрабатывается заново,...

Kafka Concurrent Consumer делает автоматическое принятие кафки в значение false. Затем, основываясь...

После увеличения времени для session_timeout и request_timeout мой потребитель kafka не получает...

У меня есть кластер Kafka с 1.1.1 версией. Недавно я обновил kafka-clients в потребительском...

Используя kafka-console-producer Я могу отправлять сообщения в тему acl, используя пользователя...

В настоящее время я работаю над проектом kafka java. Я новичок в этом, и мне трудно понять...

У меня есть следующий файл docker-compose: version: '3.1' services: postgres_db: image:...

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

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

Я читаю из потоковых данных (значения, разделенные запятыми), используя KafkaUtils

Привет, я пытаюсь использовать две разные полезные нагрузки json из одной темы, и я использую...

Я устанавливаю новый сервер весенней загрузки с kafka, и создаю KafkaProducer / KafkaConsumer с...

Насколько я понимаю, Кафка будет периодически обновлять / запоминать позиции каждого смещения...

Я работаю с Java-производителем и потребителем, я пытаюсь визуализировать свое потребительское...

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

В настоящее время я пишу kafka cosumer. Работа потребителя заключается прежде всего в создании...

Следуя обсуждению здесь , я использовал следующие шаги для включения внешнего клиента (на основе...

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

Я использовал версию Spring Kafka 1.3.8 с клиентом apache kafka 0.11.0.2. Поскольку мой брокер...

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

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

В настоящее время я хочу, чтобы мои клиенты Kafka были написаны на .Net. Хотя Java / Scala, как...

Попытка понять (новичок в kafka), как работает цикл событий опроса в kafka. Вариант использования:...

Firest Я опрашиваю данные с kafka и мне нужно читать записи с помощью асинхронных методов, я...

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