У меня есть 4 брокера кафки и 3 зоопарка, развернутые на Куберне.Из 4 работают только 2 брокера...

Я ищу шаблон и существующие реализации для моей ситуации: у меня есть синхронный soa, который...

Мой сервер устанавливает Кафку, использует docker: wurstmeister / kafka. Когда я использую...

Я настроил свою среду с помощью докера на основе этого руководства . На kafka-console-производители...

Я пытаюсь десериализовать поток байтов avro в объект класса случая scala. По сути, у меня был поток...

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

У меня есть Datastream [ObjectNode], который я прочитал как десериализованный JSON из темы Кафки....

Согласно моему текущему пониманию Кафки, данные хранятся, и каждое «местоположение магазина»...

Я использую пользовательский запрос в соединителе исходного кода JDBC kafka. Кто-нибудь может мне...

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

СБОЙ: SemanticException Не удается найти класс 'org.apache.hadoop.hive.kafka.KafkaStorageHandler' Я...

Я пытаюсь установить установку Kafka с 3-мя Kafka Brokers в одном узле zookeeper, но я вижу, как...

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

Я создаю простой API-интерфейс node.js с использованием express и kafka-node, который возвращает...

Мы работаем с 3-х брокерским кластером kafka (v2.11-2.1.0), машинами r4.xlarge на aws. У нас...

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

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

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

Я могу подключиться к моему локальному серверу kafka с пакетом python kafka. Однако я не могу...

Существует кластер Kafka (версия 2.2.0) из 3 узлов.Один узел становится искусственно недоступным...

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

На данный момент мы используем вызовы curl и GET для получения данных извне, используя их URL...

У меня есть файл JSON, который я сгенерировал с помощью aws kafka create-cluster...

Я ищу способы парковки сообщений в хранилище данных после нескольких повторных попыток и...

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