На данный момент я создаю обобщенную запись avro из фрейма данных spark с помощью файла file.avsc и...

Я просматривал эту статью , в которой объясняется, как обеспечить обработку сообщения ровно один...

У меня есть функция без сервера, которая пытается отправить некоторые данные в kafka. Иногда это...

Хочу поставить кафку темы / лаги раздела в Elasticsearch. Используя kafka burrow и telegraf. Я уже...

Я отправил спецификацию супервайзера kafka-druid, и это отражено в супервизорах в консоли...

Кафка написана на Scala в старых версиях? И только Java используется в более новых версиях? (Старый...

Я использую многопоточных потребителей кафки для одной темы кафки на 60 разделов, причем каждый...

При получении метрик потребителя через API потребителя kafka records-lag-max иногда возвращает 0,...

Если я poll() из consumer в операторе while True:, я вижу, что poll() блокирует. Если потребитель в...

Я создал тему Кафки с тремя разделами. Используя ProducerFactory в Spring-Kafka, я могу создать...

Я хочу получить список групп потребителей Kafka по темам в kafka-python, но не смог. Как я могу...

У меня в докере работает kafka и zookeeper Мне нужно отправлять сообщения kafka на kafka с помощью...

У меня есть служба весенней загрузки (2.1.3), публикующая сообщения в теме kafka (2.12-2.3.0)....

Я создаю Kafka Connector, который загружает список запрашиваемых элементов. Этот список элементов...

Как я понимаю, используя образ док-станции слияния реестра Schema (не с упругостью zookeeper, но с...

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

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

В настоящее время мы пытаемся использовать Debezium для регистрации изменений 4 таблиц в базе...

При использовании kafka я периодически получаю две ошибки, связанные с сетью. 1. Error in fetch...

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

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

У нас есть Kafka Consumer (параллелизм 5) с ручным подтверждением. В приведенной ниже реализации...

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

Уважаемые, я хочу обновить свои доменные объекты в соответствии с сообщением, полученным по теме...

Его Я не могу десериализовать строку json из темы kafka. Атрибуты находятся в смешанном случае змеи...