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

В настоящее время я использую PlainLoginModule для аутентификации пользователей. Однако теперь я...

Обзор: у меня есть лямбда-установка с Kafka Consumer, которая опрашивает сообщения из кластера...

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

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

Я пытаюсь установить cp-helm-charts . Я хочу получить доступ к топологии извне. Итак, я сделал:...

С Spring JDBC Templates вы можете лениво инициализировать соединения с помощью простого флага....

Нам нужно построить производственный кластер Kafka с 3-5 узлами в кластере, У нас есть следующие...

Я не могу использовать экспортер JMX для предоставления метрик kafka. Можете ли вы посмотреть на...

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

Я хотел бы использовать соединитель приемника s3 kafka connect для потоковой передачи данных нашей...

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

Я хотел бы настроить агент Flume, который должен читать из раздела Kafka, и сохранить данные в...

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

Мне нужно создать систему обработки сообщений с группами потребителей в Сериализированный Avro...

У меня есть 10 тем, и я отправляю 1000 сообщений брокеру каждые 5 минут, и я потерял несколько...

Я использую Spring Kafka 2.2.7, я настроил @EnableKafka с kafkaListenerContainerFactory и использую...

Confluent SchemaRegistry не работает с Quarkus и MicroProfile в результате появляется следующая...

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

В моем проекте springBoot я использую kafka прослушивающее сообщение, например:...

Я знаю, что параметру offsets.topic.replication.factor задается server.properties для брокера. Могу...

В нашем приложении мы используем потребителя kafka для определения отправки электронной почты. На...

Я пытаюсь подключить два экземпляра реестра схемы kafka к одному кластеру kafka и zookeeper. Но...

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

Я использую apachekafka последней версии 2.3.0, я развертываю kafka в качестве многоузлового...