Я написал небольшой Java-класс для проверки потребления темы, закодированной Avro, в Kafka....
До сих пор я запускал zookeeper и kafka server из командной строки перед запуском моего приложения...
Я написал программу akka, которая использует комбинацию akka stream и alpakka. У меня есть actorRef...
В метке времени в метафайле сообщения для Kafka указано время, когда производитель Kafka отправил...
Я соединяю производителя и потребителя kafka, предоставляя порт IP kafka broker.Как я могу...
Я написал микросервис в узле, который использует node-kafka. Я слышал о встроенной кафке для...
Я пытаюсь настроить примеры потоковой передачи apache kafka отсюда: https://github
Я вижу много ответов об использовании offsetsForTimes. Разве я не могу просто прочитать сообщения,...
Допустим, я звоню poll() только один раз с некоторым тайм-аутом вместо while(true) {...poll...}...
Я установил Kafka на локальный Minikube, используя диаграммы Шлема https://github
Я пытаюсь использовать https://github.com/danielqsj/kafka_exporter/, чтобы показать некоторые...
Я пытаюсь преобразовать все поля меток времени в строковый тип в формате yyyy-MM-dd HH:mm:ss. Чтобы...
Я запускаю kafka на одном узле, я хочу увидеть поведение kafka Producer, когда я выключаю свой...
Я хочу использовать интеграцию kafka для clickhouse.Я пытался использовать официальный учебник, как...
Я пытаюсь запустить простое приложение Spring Boot Kafka, но не могу заставить его работать. Я...
Я настроил HDFS Kafka Connect для работы на Azure Datalake, однако я только что заметил, что ключи...
При запуске Kafka-Connect я видел много предупреждений 10:33:56.706 [DistributedHerder] WARN org
У меня на Kafka есть следующий разъем InfluxDB: { "connector.class": "com
Я устанавливаю два экземпляра neo4j (источник и сток) с плагином neo4j-streams и Kafka между ними....
Я использую коннектор приемника JDBC и у меня плохое сообщение в теме.Я знаю, почему сообщение...
Я использую приведенный ниже код API производителя для записи сообщений в тему Kafka, но не удается...
Есть ли возможность ограничить / ограничить скорость процесса MirrorMaker , чтобы целевой кластер...
После настройки прототипа облачной службы на основе приложений Kafka и .NetCore (webapi как...
Таким образом, с приведенной ниже конфигурацией, когда мы масштабируем загрузочные контейнеры...
Существует ли минимальная скорость сообщения в Гбит / с, необходимая для выбора Kafka для потоковой...