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

Вместо создания множества тем я создаю раздел для каждого потребителя и сохраняю данные с помощью...

У меня есть функции A, B & C. Когда я вызываю функцию A (), она отправляет уведомление kafka, и...

В настоящее время мое потоковое приложение Kafka Consumer вручную фиксирует смещения в Kafka с...

Предположим, что существует только одна тема с 20 разделами и одна группа потребителей только с...

Я полностью приседаю на Kafka суше. Если я запускаю команду /cfintools/confluent-4.0

Рассмотрим следующее: const cached = this.cache.get(somekey); // console.log(!cached); if (!cached)...

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

Согласно документации Kafka; Новый потребитель Java теперь поддерживает сердцебиение из фонового...

Мой сервер работает на Flask, у которого есть некоторые конечные точки API.Используя эти конечные...

Я хотел, чтобы у Kafka был фиксированный тариф, чтобы мы могли опрашивать () тему каждые три минуты...

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

Я создал тему с 5 разделами с 3 коэффициентами репликации. У меня запущены два потребительских...

При использовании метода listTopics () из KafkaConsumer для каждой темы в кластере, где у...

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

Обычно я пытаюсь получить все столбцы, когда использую выражение group by в своем запросе. Создание...

У меня следующий сценарий, и я хотел бы понять ожидаемое поведение. Создано Kafka Consumer Kafka...

Когда я проверяю на потребительскую задержку, это показывает, что конкретный consumer-id работает с...

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

Сценарий: Я записываю данные объекта JSON данных в тему kafka во время чтения. Я хочу прочитать...

Я наткнулся на эту ссылку для заголовков кафки.Как обсуждается в приведенной ниже ссылке заголовок...

когда система находится в режиме ожидания и включено автоматическое смещение фиксации, время от...

Я вижу код Spring Kafka, и у меня есть некоторые сомнения: Если мы используем 1 @kafkaListener с 2...

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

Мы используем пружину Кафка.Я слушаю несколько тем в моем потребительском приложении (один сервер,...