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

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

Я пытаюсь создать Kafka Partition , используя JAVA. Но не удалось. Может кто-нибудь дать мне пример...

У меня есть установка Logstash 6.2x, где я читаю ввод Kafka и записываю вывод в экземпляр...

Я новичок в работе с Kafka. Могу ли я отправить сообщение с несколькими значениями?у меня есть этот...

Я уже некоторое время изучаю Apache Kafka. Давайте рассмотрим следующий пример. Предположим, у меня...

Я на самом деле строю микросистемную среду на основе JHipster.Но у нас есть несколько вопросов по...

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

Есть ли в Кафке функция (или другие очереди сообщений), с помощью которой мы можем добавлять...

Я использую kafka_2.11-1.1.0.Это мой файл server.properties: broker.id=1 num.network.threads=3 num

Я не получаю такую ​​большую пропускную способность, как мне кажется, с моим приложением this...

У меня есть 2 потока с именами «тревога» и «вмешательство», которые содержат JSON.Если тревога и...

Я пытался реализовать AuthenticateCallbackHandler, готовый к выпуску в Kafka 2.0.0, но...

Я хочу использовать потребление Kafka в Nifi, чтобы использовать тему.Исходя из этого, я хочу взять...

Я пытаюсь создать поток в Apache / KAFKA KSQL. Тема содержит (довольно сложный JSON) {...

У меня есть следующие атрибуты: OrgId DeviceId ResponseId Я хочу агрегировать количество...

Требование: Отправка данных из приложения для Android или приложения для iOS в экосистему больших...

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

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

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

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

У меня есть файл, содержащий данные в формате AVRO, которые необходимо опубликовать непосредственно...

Начиная с 0.11, Kafka Streams предлагает одноразовые гарантии, но их определение «конец» в сквозной...

Я хотел бы посчитать сообщения, приходящие из темы какфа. Например, у меня есть этот класс дел:...

Я получаю потоковые данные от Кафки.По умолчанию dataframe.value имеет тип "string".например,...