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

Я пытаюсь опубликовать авро-сообщение, используя AvroProducer confluent-kafka-python, используя...

Я следовал этому учебнику по кафке на windows.Я могу запустить zookeeper, но при запуске kafka я...

Я сделал Кафку и зоопарка как набор состояний и выставил Кафку за пределы кластера. Однако всякий...

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

В доверенном прокси-кафке остатка мы можем получить последнее зафиксированное смещение определенной...

Я написал C ++ потребитель для сообщений kafka, используя библиотеку cppkafka (обертка для...

Я запускаю Hyperledger в рабочем состоянии и перезапускаю всю сеть (включая всех брокеров kafka), и...

I have enabled Kerberos via Ambari in all Hadoop components. I am using HDP v3.1.0 and Kafka...

Мы используем Spring Kafka для потребления записей партиями. Иногда мы сталкиваемся с проблемой,...

Я пытаюсь создать объект CachedSchemaRegistryClient, используя confluent-kafka python api.Но это...

У меня есть веб-страница, на которой необходимо отправить сообщение kafka в тему. Сеть использует...

У меня есть один брокер, работающий на моей локальной машине с ОС Windows, в котором есть 2-3 темы...

У меня есть Kafka AdminClient, что когда Kafkaserver активен, он вернет true, иначе false. private...

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

У меня есть простой слушатель kafka в приложении Springboot, например:...

Попытка запустить Kafka 2.3.0, выполнив шаги, указанные в официальной документации здесь . Но на...

Работа над проектом с использованием клиента .net confluent kafka, получение исключения при...

У меня есть данные, поступающие в Kafka, я хочу отправить данные из kafka в базу данных...

Я получил сообщение об ошибке «Объект типа mappingproxy не поддерживает сериализацию JSON» при...

Я использую Kafka-Node в своем приложении NodeJS для создания и получения сообщений.Я начинаю...

kafka-python 1.4.6 Python 3.7.3 debezium / kafka 0.9 Я использую kafka-python для настройки своей...

Мы работаем с кластером Apache Kafka 1.1.0 с 5 брокерами. Поскольку управление машинами...

Когда я запускаю свое Java-приложение и создаю экземпляр объекта KafkaConsumer (снабжается...

Я работаю над доступом к Kafka серверам с включенным ssl.Таким образом, поток используется с...