Я пытаюсь использовать wurstmeister\kafka-docker образ с docker-compose, но у меня есть реальные...

во время выполнения получения кода kafka 1) ОШИБКА StreamExecution: Запрос [id =...

Я использую компьютер, который имеет 2 версии 32-битной и 64-битной Java.Я хочу запустить Кафку, и...

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

Моя конфигурация: Confluent (5.0.0) Kafka выдает несколько авро-сообщений. Рабочий Connect...

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

У меня есть один потребитель Kafka, который использует несколько тем Kafka.Я хотел бы иметь...

Я новенький моргать и кафка. Я пытаюсь десериализовать данные avro с помощью реестра Confluent...

Я настраиваю лося с помощью kafka и хочу отправить журнал через 2 раздела kafka (topic1 для...

У меня 3 подчиненных узла в k8s, и я запускаю kafka (3 кластера). При развертывании zk / broker /...

В настоящее время у нас нет большой нагрузки на Кафку. Но мы ожидаем некоторую достойную нагрузку в...

Для этого я запустил Zookeeper: bin/zookeeper-server-start.sh config/zookeeper.properties , а затем...

У меня есть приложение Django, которое имеет интеграцию с Kafka для обработки некоторых заказов

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

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

Я использую EmbeddedKafka для тестирования моего модуля со следующей конфигурацией аннотаций:...

Я довольно новичок в Python.У меня есть веб-приложение на основе Django, где я выполняю некоторые...

Есть ли способ разложить сообщения так, чтобы использовалось только последнее сообщение? Я пытался...

Попытка создать и заполнить схему массива типа string внутри схемы массива определенного типа...

Привет, поэтому я пытался настроить простой потребитель Кафки в Java, который выглядит следующим...

Кто-нибудь сталкивался с этой ошибкой? io.confluent.kafka.schemaregistry.client.rest.exceptions

Когда я увидел это сообщение об ошибке: ОШИБКА Брокер выключения, потому что все каталоги журналов...

У нас есть бизнес-процесс / рабочий процесс, который запускается при получении исходного сообщения...

Я ищу способ удалить тему или все ее сообщения, используя kafkacat.Это возможно или единственный...

В настоящее время я борюсь с потребителем на kafka, который может каким-то образом запланировать на...