У меня есть приложение для потокового воспроизведения, которое запускается в конце дня и использует...
Мое требование - сбросить смещение темы kafka, когда приложению не удалось обработать сообщение,...
Я создал SparkConsumer, чтобы я мог отправить файл CSV в Kafka через Spark Structured Streaming. Я...
У меня запущено приложение kafka stream, которое будет принимать сообщения из темы всякий раз,...
Я экспериментирую на Kafka с Spring Boot. Spring Boot 2.1.0.RELEASE Spring-Kafka 2.2.0 Iиметь...
Я знаю, используя API-интерфейсы потребителей Kafka, мы можем получить смещение, соответствующее...
Я пытаюсь получить какие-то метрики (клиентское отставание, ...) от Кафки, чтобы предоставить его...
Я хочу реализовать механизм зеркалирования между брокерами kafka и найти потоки kafka как хорошее...
Я собираюсь создать потоковое приложение Kafka на основе Java, которое будет непрерывно слушать...
Должен ли я использовать Kafka Consumer API или Kafka Streams API для этого варианта использования?...
Я хотел бы использовать сообщения.Если я получу исключение, я попытаюсь повторить экспоненциальный...
У меня есть производитель и потребитель Кафки. Производитель делает это: const returnMessage = {...
Как настроить потоки Кафки для использования следующего сообщения только при получении...
Часть моей искровой работы: val kafkaParams = Map[String, Object]( "key.deserializer"...
Я использую клиент на основе RD Kafka C для приема / выдачи сообщений в Kafka Broker.Некоторое...
Я использую kafka-python для создания потребителя Kafka (подключенного к производителю Kafka,...
Если у меня есть записи ниже {"A",7} {"B",10} {"C",10} Тогда...
Я читаю сообщения от Кафки в приложении Spark Streaming. Продолжительность SparkBatch: 15 сек
У меня есть два потока приложений kafka. Я могу видеть там группы потребителей, используя:...
моя версия для потокового воспроизведения - 2.0, версия для kafka - 0.10.0.1,...
При запуске My spark Kafka Direct Stream будут использоваться только те сообщения, которые были...
Я создал образец темы в kafka и пытаюсь использовать содержимое в spark, используя приведенный ниже...
Используя коннектор kafka, я записываю данные в формате avro в тему kafka, а затем, используя...
Я уже видел подобный вопрос, как нажмите здесь Но все же я хочу знать, если потоковая передача...
Я пытаюсь создать масштабируемый конвейер, который будет получать сообщения от Kafka и отправлять...