Целью настройки transactional.id для продюсера, в моем понимании, является защита от производителя...
Я немного запутался в связи между max.in.flight.requests.per.connection для Kafka Producers и...
Я пытаюсь получить время фиксации для определенного смещения группы потребителей.Я проверил API...
Я могу заставить моего производителя Apache Kafka отправлять сообщения, когда он работает внутри...
Я использую apache camel kafka в качестве клиента для создания сообщения. Я наблюдал, как...
Я использую ReplyingKafkaTemplate в моем контроллере Rest для возврата синхронного ответа.Я также...
У меня есть загрузочное приложение Spring с очень простым производителем кафки.Все отлично работает...
На данный момент мы используем вызовы curl и GET для получения данных извне, используя их URL...
Клиенты KAFKA (производитель и потребитель) обнаруживают топологию, подключаясь к одному из...
У меня проблема с созданием сообщений в теме Кафки. При создании нескольких сообщений в теме Кафки...
Я использую весеннюю интеграцию с API производителя kafka.Я хочу остановить мой API-интерфейс...
Я пытаюсь запросить хранилище состояний, чтобы получить данные в окне за 5 минут.Для этого я...
Используя тему и ключ сообщения, Кафка назначает раздел темы на основе: ... Utils.Murmur2(bytes) %...
Оказывают ли влияние режимы подтверждения («0», «1», «все»), когда мы отправляем сообщения с...
Я использую метод KafkaProducer.send () для публикации записей в Kafka. Это асинхронный метод. Мое...
Используя шаблон Spring Kafka, у меня есть 2 разных производителя, которые отправляют разные...
Мне нужно отловить исключения в случае асинхронной отправки в Кафку.Api-производитель Kafka...
Я только начинаю с Kafka, это звучит очень хорошо для Microservices, но я работаю в основном в...
С точно один раз KIP , касающийся идемпотентности производителя при перезапуске приложения с...
Есть ли способ получить общее время запроса от kafka.network:type=RequestMetrics,name=TotalTimeMs...
Надеюсь, у вас все хорошо. Постановка проблемы: Разработайте потоковый анализ, который вызовет...
Глядя на документацию, я не уверен, что понимаю разницу между использованием close () и flush () ....
Мне известен метод metric(), доступный в Kafka API для метрик производителя. Я на самом деле...
Создание Kafka Producer с конфигурацией "acks = all". Имеет ли какое-либо значение вызов флеша с...
Я работаю с производителем Kafka на локальной машине, используя мою Intellij IDE, и продюсер будет...