я использую версию spark-sql-2.4.1 с Kafka 0.10 v. Пока я пытаюсь использовать данные потребителем....

Я использую Kafka версии 2.2.0cp2 через Rest Proxy (в контейнере Docker). Мне нужно, чтобы...

У нас есть микросервисная архитектура, и мы хотим публиковать события в темах Kafka для...

Где находится значение max.partition.fetch.bytes в клиенте Kafka? Я не нашел ни одного имени...

Я использую Задачу Мойки Кафки для чтения записей из темы Кафки. Метод put () в SinkTask - это...

У меня есть тема с 50 разделами и группа потребителей, слушающая эту тему. Я использую приведенную...

Я пытаюсь создать потребителя Kafka, который может читать из темы Kafka. Чтобы сделать это, я...

В нашем приложении мы используем потребителя kafka для определения отправки электронной почты. На...

Скажем, я хочу проверить смещение первого и последнего сообщения в Кафке для определенного раздела....

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

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

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

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

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

Есть ли способ для потребителя Kafka читать напрямую из AWS Kinesis Stream? Azure EventHub...

Я новичок в Kafka и пытаюсь создать кластер Kafka с 3 узлами для высокой доступности. Я следовал...

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

При подтверждении вручную kafka, при использовании / обработке огромного количества сообщений, мы...

Я установил Docker на мою Windows 10, а также установил Kafka. Я создал тему " test " внутри...

У меня есть кластер Kafka, настроенный с использованием трех экземпляров виртуальной машины GCP. На...

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

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

У меня есть несколько экземпляров одного и того же сервиса, подписанного на тему Kafka....

Я хотел понять, имея большое количество потребителей по задержке производителей и брокеров. У меня...

Я изучаю Apache Kafka для создания приложения, и оно действительно соответствует нашим потребностям