apache-kafka

0зной

1ответ

Проблемы при запуске kafka connect в распределенном режиме

Мы тестируем соединение kafka в распределенном режиме, чтобы вытащить записи тем из kafka в HDFS. У нас есть две коробки. Один, в котором работают демоны кафки и зокпера. Мы сохранили один экземпляр п

-1зной

1ответ

Как вы создаете сайт для продажи Flash?

Если на странице указано 30 000 предметов в инвентаре, и мы показываем их как список, как мы архивируем поток данных на эту страницу в виде Push, что не подавляет пользователя слишком большим количест

1зной

1ответ

Предварительная проверка сообщений, отправленных на тему Кафки

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

0зной

1ответ

Функциональность Log4J-Kafka в Apache Spark/scala

Привет Я пытаюсь войти в тему Kafka из группы исполнителей, использующих Apache Spark с Log4J и дополнением Kafka-Appender. Я могу регистрироваться с исполнителями, используя базовый File Appender, но

0зной

1ответ

Pyspark Kafka диапазоны смещения

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

4зной

1ответ

Идеальное значение для настройки конфигурации распределенных задач Kafka Connect?

Я ищу продукт для ионизации и развертывания приложения Kafka Connect. Тем не менее, есть два вопроса, которые у меня есть о задаче task.max, который требуется и имеет большое значение, но детали неясн

2зной

1ответ

MapR Stream и PySpark

Поддерживает ли PySpark совместимость с потоками MapR? Любой пример кода? Я пробовал, но получаю Exception strLoc = '/Path1:Stream1' protocol = 'file://' if (strLoc.startswith('/') or strLoc.startswi