Можно ли использовать avro DataFileWriter с реестром схемы?
Я пишу бакалавру о небольшой распределенной системе с Apache Kafka, использующей c #.Мне нужно...
есть ли мост, который может отправлять данные из темы кафки в amqp (rabbitmq) или mqtt? Я просто...
Я пытаюсь поместить большое количество сообщений (350 МБ) в тему клиента (исходную тему) с таким...
Я пытаюсь написать потребителя Kafka, где я передаю все документы в теме.И я хочу закрыть...
1.env Kafka версия: 0.11.0.1. 2.Задача desc Независимо от того, сколько узлов kafka, если...
В Документация Apache Kafka они используют ключевое слово PLAINTEXT в качестве протокола во многих...
Я создал исходную подписку на тему, у которой есть входное сообщение, подобное этому: {...
Мне нужно написать несколько слушателей, которые будут слушать разные темы.Как только они получат...
Я учу друида сейчас.Я читал, что прием через Kafka Indexing Service гарантирует семантику "точно...
У меня есть сквозной конвейер веб-приложения, как показано ниже в Python3.6 Socket(connection from...
Проблема У меня есть настройка Kafka с тремя брокерами в Кубернетесе, настроенная в соответствии с...
Хотите знать, как восстановиться в уникальной ситуации, когда zookeeper, похоже, имеет метаданные...
Я установил простую капельку в Digital Ocean и использую один узел Kafka и Zookeeper, который...
Я создаю Java-приложение, в котором есть несколько JSON объектов (в частности, объектов AnyJson из...
Я пытаюсь разработать приложение, которое считывает байтовые массивы (представляющие структуру C и...
@ Fabian Hueske Я пытался указать такую схему, когда читаю из kafka, и скрываю inputtream 2...
Мы используем Kafka, Avro и Avro Schema Registry.Учитывая набор тем, которые я хочу использовать,...
Я хочу реализовать Kafka для обмена сообщениями через распределенную микросервисную архитектуру. Я...
Если у меня один и тот же идентификатор группы Кафки, но используемый в разных кластерах Кафки,...
Учитывая, что 1. Кластер Kafka с пятью машинами 2. 1 раздел с 1 разделом 3. Постоянное хранилище...
Я реализовал Java Consumer, который потребляет сообщения из раздела Kafka, которые затем...
Я пытаюсь утопить мой стол mysql вasticsearch.В моей таблице более миллиона записей.Проблема в том,...
У меня есть кластер Kafka с 3-мя брокерами, настроенными следующим образом: Broker-0 : broker.id=0...
Среда: spring-boot.version - 1.5.9.RELEASE spring-kafka.version - 1.2.0.RELEASE Клиентская версия...