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

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

Я исследую некоторые вещи для работы, где мы должны доказать ценность Kafka и KSQL как части POC....

У меня есть извлечение данных из Cisco Prime API, который, помимо прочего, содержит MAC-адрес точек...

У меня есть кластер Hadoop на базе HDP 3.1 с HDFS, Hive и Kafka. Я создал тему test_topic, в...

Я не знаю, как настроить Kafka для Symfony messenger. Все работает для rabbitmq (я создал...

Я довольно новичок в докере. Моя проблема в том, что у меня есть мультиконтейнерное приложение...

Есть тема Kafka Consumer, для которой я хочу получить время отклика функции потребителя в новой...

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

Предположим, у меня есть три сервера Kafka (независимо друг от друга), и у меня есть один объект...

Мы работаем над проектом, который заключается в сборе данных из ERP и хранении в нашей базе данных,...

Я пытаюсь прочитать тему Кафки, используя Apache Beam, Google Dataflow. Вот код: public class...

Я устанавливаю новый сервер весенней загрузки с kafka, и создаю KafkaProducer / KafkaConsumer с...

У меня есть 3-брокерская установка Kafka без реплики на Azure K8S, использующая cp-kafka 5.0.1 helm...

У меня есть потребительское приложение kafka, где в методе слушателя аннотируется @Kafkalistener. Я...

Я имею в виду Файл конфигурации входа в систему JAAS . В нем рассказывается о двух способах...

У нас есть кластер Kafka, который использует Kafka 2.1.1, и мы используем встроенный соединитель...

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

У меня проблема с kafka и php, которую я не мог понять: у меня 3 сервера с php 7.4, php-rdkafka...

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

ReadLg.java package com.example.dev1.controller; import java.io.BufferedReader; import java.io

Могу ли я сравнить keyedDataStream с keyedPatternStream? Если это так, пожалуйста, кратко,...

Я пытаюсь удалить эти Acls: navdeploy@swe-analyticsdb-prod2:/remote/sde108/kafka/kafka/config % .

Когда я пытаюсь использовать executorService (фиксированный пул потоков из 50) с Kafka, некоторые...

Я очень новичок в мире Кафки и Авро. Я хотел бы использовать Avro + Schema Registry для Kafka. Тем...