Кафка тема на одного производителя

Допустим, у меня есть несколько устройств. Каждое устройство имеет разные типы датчиков. Теперь я хочу отправить данные с каждого устройства для каждого датч...

Разница между session.timeout.ms и max.poll.interval.ms для Kafka 0.10.0.0 и более поздних версий

Мне непонятно, зачем нам оба

Проблемы с конфигурацией и производительностью Kafka

Я пробую кафку как альтернативу AWS SQS. Мотивация в первую очередь заключается в повышении производительности, когда kafka устранит ограничение одновременно...

Ограничить размер пакетов Kafka при использовании Spark Streaming

Можно ли ограничить размер пакетов, возвращаемых потребителем Kafka для Spark Streaming?Я спрашиваю, потому что у первой партии, которую я получаю, есть сотн...

Кафка потокового параллелизма?

У меня есть некоторый базовый код Kafka Streaming, который читает записи из одной темы, выполняет некоторую обработку и выводит записи в другую тему.Как пото...

Как использовать приложение Android в качестве «клиента-производителя» для Kafka?

Как получить смещения групп потребителей для раздела в Golang Kafka 10

Теперь, когда библиотека Golang Kafka (sarama) предоставляет возможность группам потребителей без какой-либо внешней помощи библиотеки с помощью kafka 10. Ка...

Получение ошибки NoClassDefFoundError: org.apache.spark.internal.Logging на Kafka Spark Stream

Я получаю ошибку во время выполнения, запустив ниже Java-код,Нужно ли включать какие-либо зависимости для ведения журнала, например, log4js или что-то еще?По...

Как я могу получить значение смещения в KStream

Как преобразовать JavaPairInputDStream в DataSet / DataFrame в Spark

Я пытаюсь получить потоковые данные отКафка, В этом процессе я могу получать и хранить потоковые данные вJavaPairInputDStream, Теперь мне нужно проанализиров...