Как добавить заголовок, используя KStream API (Java).
Я пытаюсь сохранить результат запроса ksql (оконную таблицу) в базу данных, используя kafka connect
Итак, я получил несколько досадных компромиссов с моими потребителями кафки.Я использую...
Я интегрировал opentracing с kafka в приложении Java и с помощью клиента Jaeger. Можно ли добавить...
У меня фиксированное количество разделов темы. Производители производят данные с разной скоростью в...
Я следовал этому уроку шаг за шагом, чтобы настроить Kafka в Openshift с помощью оператора strmizi:...
Мы установили кворум зоокейпера (3 узла) и 3 брокера кафки. Производители не могут отправить запись...
Керберизованный кластер Hadoop. Connect-Instance запущен на пограничном узле. В автономном режиме...
Я использую Кафку уже несколько месяцев, и я понял, что некоторые из основных понятий мне пока не...
У меня есть следующий маршрут.Странно, что пользовательское значение заголовка «myHeader» теряется...
Я использую Spring Framework и Kafka, в котором есть 3 кластера. Я обнаружил, что потребитель не...
Я сейчас настраиваю Apache Kafka с аутентификацией SSL и сталкиваюсь с ошибкой при запуске сервиса
Может ли преобразователь значений Kafka connect (JSONConverter) использоваться для преобразования...
Смещение сбрасывается, когда одна тема используется двумя разными группами потребителей. Я...
Каким будет лучший дизайн / решение для обнаружения проблемного сообщения, опрошенного в теме Kafka...
Я использую данные из 5 тем, используя два разных идентификатора группы («живой» и «ночной») для...
Kafka не запускается со следующей конфигурацией (взятой из сценария службы systemd): [Service]...
Несмотря на то, что клиенты kafka проходят проверку подлинности и могут быть ограничены...
Я пытаюсь решить проблему, когда одна клиентская сторона отправляет UDP-пакет, который будет...
Я следую этому уроку: Начало работы с Spark Streaming с Python и Kafka Я копирую код в мой Блокнот...
Я установил Kafka и провожу базовое тестирование.Я могу создавать темы, используя сценарии, которые...
Я пытаюсь опубликовать какое-то сообщение, используя kafka customer с "replyingKafkaTemplate".Моя...
Я написал Kafka Avro Deserializer, используя файл схемы Avro с сгенерированным исходным кодом Java....
Я ищу самый быстрый грузоотправитель бревен, который может напрямую передавать мои бревна в...
С точно один раз KIP , касающийся идемпотентности производителя при перезапуске приложения с...