У меня есть несколько списков, которые я хочу отправить через продюсера Kafka. listA [1,2,3] listB ["cat", "dog", "fish"] производитель отправляет сообщения в байтах, поэтому я не уверен, как правильно настроить ...
Существует ли минимальная скорость сообщения в Гбит / с, необходимая для выбора Кафки для потоковой передачи в реальном времени? Можем ли мы справиться с очень низким уровнем сообщений в Кафке?
Попытка понять API производителя Java. Что означает завершение? Помоги мне понять за то же самое. Ссылка: https: //kafka.apache.org/0110/javadoc/index.html? Org / apache / kafka / clients / ...
У меня есть вопрос о том, как мы можем интегрировать производителя kafka с веб-приложением. получить данные за каждую минуту или секунду. Может ли веб-приложение каждый раз передавать объект JSON работающему производителю ...
Продюсер Кафки имеет возможность выполнять микропакеты для операции отправки на основе batch.size и linger.ms для повышения производительности производителя. Однако даже если сообщения ...
Я строю планировщик корпоративных событий на основе потоков Kafka. Запланированные события собираются или генерируются из микросервисов в облаке. Каждый микросервис будет иметь около 200 рабочих ...
у нас есть 5 брокеров кафки, фактор репликации 3 и 2 темы - T1 и T2. Тема T1 имеет 100 разделов, T2 имеет 6. при записи с производителем kafka (используя KafkaProducer.send ()) на T1 и T2, ...
Я хочу использовать Кафку в нашей производственной среде. Я хочу знать, если последняя версия клиента без ошибок для запуска производства. Работает ли это с группой потребителей? Я хочу передать 10000 записей за ...
Я хочу убедиться, что сервер kafka запущен или нет перед запуском производственных и потребительских заданий. Это в среде Windows, и вот мой код сервера kafka в затмении ... Свойства kafka = ...