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

У меня есть следующий код //Kafka Config setup Properties props = ...; //setup List<String>...

Каков будет подход к подписке на любые сообщения в теме Kafka из подписки GraphQL? Кажется, что...

Я пытаюсь смоделировать Gwen (Chen) проект Кафки-clickstream-enrich kafka-stream Шапиры на GitHub...

kafka версия: 0.9.0.1 Если n = 20, я должен получить последние 20 сообщений по теме. сейчас я...

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

У меня есть входные данные, которые я получаю, используя Kafka Stream.То, что мне нужно реализовать...

Я пытаюсь создать приложение KStream в Eclipse, используя Java. сейчас я имею в виду программу...

Я реализовал простой процессор записи мертвых букв Kafka. Он отлично работает при использовании...

Я хочу использовать поток Кафки в MySQL, используя Python;если я хочу создать панель мониторинга в...

Я пытаюсь подключить свое приложение React к серверу Kafka.Я ожидаю, что мое приложение React будет...

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

Я хочу суммировать данные одного столбца на основе указанного ключа.Поток похож на id (String) Ключ...

Что означает, что в столбце CURRENT-OFFSET отображается "-"? TOPIC PARTITION CURRENT-OFFSET...

STREAM-1: [KSTREAM-SOURCE-0000000000]: null, {"id": 1, "name": "john"...

У меня есть объект потока kafka, подобный этому: [KSTREAM-SOURCE-0000000000]: null,...

Я недавно обновился с kafka 0.10.1 до 1.1.0. Мое потоковое приложение создает потоки, подписываясь...