Каков наилучший способ проверить, сколько событий потребляется приложением из темы Kafka за...

Моя проблема заключается в следующем: У меня есть 2 темы kafka: customer-purchase: содержит...

Я написал код для извлечения записей из кафки в спарк.Я столкнулся с каким-то странным поведением

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

Team, Какой стратегии следует придерживаться при развертывании приложений Kafka-streams? У нас есть...

Я использую kafka_2.11-1.1.0.Это мой файл server.properties: broker.id=1 num.network.threads=3 num

Я пытаюсь опросить тему kafka с помощью API KafkaConsumer. Но он переходит в состояние ожидания на...

Я использую Spring Cloud Stream 1.3.2.RELEASE , чтобы опубликовать строковое сообщение для Кафки....

Я запускаю приведенный ниже код и после чтения нескольких RDD из Kafka я получаю эту ошибку...

В соответствующей документации kafka сказано, что класс Consumer определен следующим образом: Class...

Примеры github page для библиотеки Confluent Kafka содержат два метода, а именно опрос и...