Я запускаю kafka_2.11-2.0.0 на машине с Ubuntu 16.04. Создал тему и выдал ей несколько сообщений из...
Мы используем Кафку 1.11 наша системная задача состоит в том, чтобы удерживать низкую задержку на...
Я знаю, что могу получить всех потребителей, которые назначены для разделов, используя:...
Я использую пружинную кафку со следующими конфигурациями: props.put(ConsumerConfig
Если я определю метод, который возвращает универсальный класс, как я могу это сделать, чем...
Я новичок в kafka, у меня есть следующий пример кода: KafkaConsumer<String,String> kc = new...
Я хочу получить список групп потребителей Kafka с python, но не смог. Я использую zookeeper python...
Я строю проект, в котором для Project Target Frame используется .NET Framework 4.0, я не могу...
Я супер новый для Кафки. Я установил kafka и zookeeper с помощью homebrew на моем Mac, и я играю с...
Я использую org.apache.kafka.clients.consumer.KafkaConsumer в своем приложении для обработки...
Итак, я написал простую программу kafka, которая отправляет сообщение производителю, но когда я...
у нас есть одна группа потребителей и три темы, все три темы имеют разные схемы.создал одного...
Как мы можем использовать пользовательские сообщения из нескольких или одного раздела в теме Kafka?...
Есть метод poll для опроса ConsumerRecords, но он не может указать размер записи, как опросить...
Прежде чем присоединить потребителей к новой теме, я создаю новую тему и выдаю первое сообщение в...
У меня есть пакетное задание, которое заполняет данные в теме Кафки. Каждое сообщение имеет данные...
У меня есть один потребитель, которого я инициализирую списком брокеров (bootstrap.servers). В...
Я пробую потоковые журналы из log4j2 в топик Кафки. Мой сервер zookeeper & kafka работает. Я уже...
Я читаю сообщения Кафки, используя простой потребитель Кафки. Сохранение вывода в HDFS и некоторая...
Запись в Kafka неблокирующая, но чтение из нее блокирует поток. Почему метод опроса Kafka не...
мы создаем какой-то конвейер бизнес-процессов с использованием wso2 и kafka. Знаете ли вы, можно ли...
Я создал тему kafka на одном из моих компьютеров с IP-адресом 192.168.25.50 с именем темы test-poc....
У меня есть этот код, который загружается, когда запускается мой узел, я просто изменил этот код с...
У меня есть пользовательский потребитель Kafka, в котором я использую для отправки некоторых...
Я использую производителя kafka и потребителя Spring kafka. Я использую сериализатор и...