Я разрабатываю задание GCP Cloud Dataflow, в котором используется брокер Kafka и реестр схем.Наш...

Я рассматриваю, как развернуть наш кластер kafka: большой кластер с несколькими группами брокеров...

Я новичок в Кафке, используя c #Раньше все работало нормально.Но теперь сервер кафки падает со...

Я пытаюсь настроить аутентификацию SASL_PLAINTEXT для брокера kafka, ниже моя конфигурация....

Мне нужно сохранить вложенные объекты данных с непредсказуемыми именами в схеме Avro.Например: {...

Команды kafka через awscli не поддерживаются в ubuntu?Нужно ли использовать «Amazon Linux 2 AMI...

Я использую клиент Flink (1.7) kafka и Avro4s (2.0.4), я хочу сериализовать в байтовый массив:...

Я хотел бы создавать сообщения из контейнера A на тему Kafka в контейнере B, но у меня возникают...

У меня есть два хоста в двух разных виртуальных машинах, у меня есть flume на хосте Centos 7 и...

Если у меня есть полезная нагрузка AVRO, представляющая собой очень большое сообщение JSON, скажем,...

Создание Kafka Producer с конфигурацией "acks = all". Имеет ли какое-либо значение вызов флеша с...

Для мультитенантного кластера kafka я хотел бы контролировать распределение разделов по темам на...

Мне нужно реплицировать темы кафки из одного кластера в другой, используя процесс Java. Новые...

Я недавно установил cloudera quickstartVM, используя образ докера, и настроил в нем пакет Kafka....

Я работаю с производителем Kafka на локальной машине, используя мою Intellij IDE, и продюсер будет...

У нас есть класс utils, который будет сбрасывать смещения для данной группы потребителей.Вот...

В настоящее время мы настраиваем торговый движок и в основном все настроили в отношении того, как...

Я пытаюсь собрать метрики тем kafka, используя JMX, чтобы я мог упаковать их в объект в java

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

.NET / Java-приложение генерирует количество объектов json (15.00-90.000) в секунду, которое...

Я пытался повторить шаги, описанные в блоге . При попытке получить код Python Kafka Consumer и...

Я пытаюсь интегрировать MongoDB и Storm-Kafka, Kafka Producer производит данные из MongoDB, но не...

Допустим, у нас есть одна тема "topic-1" в kafka с разделом 5. Потребительская группа A с 5...

У меня есть приложение Spring Boot, использующее Spring-Kafka, и я использую fast-data-dev от...

Я выставляю порт 9092, затем запускаю брокер Кафки внутри докера. Но когда я запускаю скрипт python...