Мое требование заключается в том, чтобы я получил файл JSON из раздела Kafka в Kafka Stream, из...

У меня пружинный микросервис с использованием кафки. Вот свойства конфигурации потребителя 5:...

Мой потребитель привязан к анонимной группе потребителей вместо указанной мной группы потребителей....

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

Здравствуйте, я пишу kafka-потребителя-производителя с использованием весеннего облачного потока

Ниже показано, как я читаю данные из kafka. val inputDf = spark.readStream

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

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

Я пытаюсь удалить тему Кафки __Consumer_offset, так как это вызывает много недоразумений у моих...

У меня есть приложение Spring boot mongo db, когда я запускаю это приложение, если хост mongo жив,...

У меня есть случай, когда каждую секунду 5k сообщений отправляются в тему kafka. На стороне...

Я читаю потоковые сообщения, используя KafkaUtils.createDirectStream и использую commitAsync для...

При использовании из темы Kafka с использованием консоли Kafka Consumer или kt (инструмент GoLang...

У меня настроен потребитель Kafka в Spring Boot.Вот класс конфигурации: @EnableKafka @Configuration...

Я использую librdkafka C API потребителя (в частности, rd_kafka_consumer_poll для чтения, и я...

В соответствии с решением, упомянутым здесь...

Я настроил несколько потребителей Kafka в Spring Boot.Вот как выглядит файл kafka.properties (здесь...

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

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

Мне нужно сохранить потоковые данные в майскую базу данных Casandra, используя Kafka spark stream....

Я использую процессор kafka api и создаю хранилище состояний из темы из 3 разделов (у меня есть 3...

Я пытаюсь вставить данные из Кафки в Кассандру, используя 1 узел искры и 1 узел Кассандры.Фрагмент...

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

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

Я работаю над Spring Boot 2.1.1, который должен общаться с Кафкой В таком состоянии приложение...