Я разрабатываю микросервис, в котором мне необходимо запросить два разных микросервиса с помощью...
Я смотрю на исходный код KafkaConsumer здесь .Посмотрев на исходный код (который находится в Java,...
Не могу сделать ни один пример компиляции, не говоря уже о работе.Что я делаю неправильно?Запущено...
Я установил Kafka на Docker Swarm, но я постоянно сталкиваюсь с проблемой ниже. Может кто-нибудь...
Мой главный вопрос: почему происходит сбой реестра схемы? Периферийный вопрос: почему запускаются...
Следуя инструкции «Интеграция Kafka и Storm: примеры кода и состояние игры» - http://www.michael...
Может ли Apache Helix сбалансировать данные между узлами?Например, я разрабатываю базу данных в...
Я пытаюсь использовать производителя консоли Kafka, kafka-console-producer.Кажется, что по...
Привет! У меня есть данные о потребителях кафки.Следующая команда дает мне тайм-аут команды группы...
Я записываю поток данных Kafka в ведущий приемник по пути HDFS.Кафка выдает строковые данные
Я пытаюсь разработать два класса конфигурации производителя с разными типами сериализации (JSONNode...
Я пытаюсь использовать ruby-kafka https://github.com/zendesk/ruby-kafka, и я использую его...
Я использую версию 1.1 Kafka с подключением Kafka, и я сталкиваюсь с ошибкой, которую не понимаю.Я...
Мой проект реализует мультитенантность на уровне Kafka, используя отдельную тему для каждого...
У меня есть следующий кластер: Kafka -> какой-нибудь сборщик журналов -> Elasticsearch Моя проблема...
У меня есть требование создать приложение потоков Kafka, которое может обслуживать 3 требования, а...
Я пытаюсь написать потребительский код Kafka, используя Scala. У меня есть кластер Kafka (сервер A)...
У меня есть среда Kafka (Zookeeper + Kafka Server + Kafka-Connect), которая отлично работает, когда...
Я хочу, чтобы мой потребитель kafka слушал сервер kafka только с 8:00 до 20:00.Он не должен слушать...
В настоящее время я разработал код, который будет отображать тему, раздел и смещение журнала.Но в...
Я делаю приложение, которое выбирает данные изasticsearch и отправляет их в kafka.Но функция...
У меня есть простое приложение (Java), которое слушает тему Кафки, используя Camel.Это название...
Я получаю метрику Кафки с помощью Jmxtrans через порт JMX и пытаюсь опубликовать ее в CloudWatch
Я хочу запустить kafka-zookeeper через docker-compose.Я создал один файл docker-compose.yml, и он...
У меня проблема с регистрацией SLF4J на Apache Kafka.Я хочу использовать Tomcats Servlet Container...