Я создаю тему кафки следующим образом: kafka-topics --create --zookeeper xx.xxx.xx:2181...

Я использую kafka_2.11-2.1.1 и Производитель использует пружину 2.1.0.RELEASE. Я использую Spring,...

Сколько запросов метаданных сделает производитель Kafka? по одному на сообщение, по одному на пакет...

2 производители создают сообщения подобного типа в однораздельной теме. Сообщения похожи по размеру...

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

Я пытаюсь отправить массовое сообщение из 10 тыс. Записей в тему кафки.Приложение Producer работает...

Производитель Kafka пытается отправить массовое сообщение (10 КБ) за раз, но после передачи 3 КБ...

У меня есть приложение Kafka Streams с несколькими схемами, которое обогащает запись через...

У нас есть производитель кафки для данных mqtt.Ниже приведен мой скрипт на python: import paho.mqtt

Я использую spring-kafka в приложении spring-boot для отправки темы данных.Мне нужно получить...

Я пытаюсь закодировать объект класса для отправки с использованием производителя kafka. Класс имеет...

Как мне получить размер одной записи в Kafka? Существует некоторая информация о том, зачем мне это...

У меня есть ряд тем по кафке со значительным отставанием для конкретной группы потребителей.Кажется...

Я использую Confluent.Kafka string kafkaEndpoint = "127.0.0.1:9092"; string kafkaTopic =...

Я публикую сообщения внешней команде, которая принимает сообщения для Кафки и возвращает нам ответ

Я пытаюсь создать панель мониторинга в реальном времени в kibana для мониторинга тестов jmeter без...

Я сталкиваюсь с некоторой потерей данных всякий раз, когда брокер Kafka выходит из строя и...

У меня есть тема с сообщениями, и есть потребитель с именем группы как "KafkaConsumerExample".когда...

У меня есть приложение kafka streams (Kafka v1.1.0) с несколькими (24) темами.Четыре из этих тем...

Мы настроили трехузловой кластер kafka и создали тему с коэффициентом репликации 3. Мы создаем...

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

Я использую Kafka в системе чтения-процесса-записи и хочу использовать только один раз обработку....

Я пытаюсь настроить производителя kafka с KafkaAvroSerialzer для значения. И я сталкиваюсь с этой...

Mine - это приложение Springboot. В моем коде упругого поиска есть kafka-потребители.Итак, при...

В развертывании Kafka пользовательская логика разделителя тем используется для маршрутизации всех...