camus

1зной

1ответ

Каково ожидаемое поведение откат/откат Camus?

Мы эксплуатируем Камю около года успешно тянуть Avro полезных нагрузок от Кафки (версия 0.82) и хранить в .avro файлы в HDFS, используя только несколько Кафку темы. Недавно новая команда в нашей компа

0зной

1ответ

Настройка частоты для работы Camus

Я только что начал с Camus. Я каждый час планирую работать на Camus. Мы получаем ~ 80000000 сообщений (с размером ~ 4 Кбайт) каждый час. Как установить следующие свойства: # max historical time that w

0зной

1ответ

Передача файла свойств в Oozie Java Action

У меня есть рабочий процесс Java-азартной игры, который я планирую использовать для планирования координатора Oozie. Действие java запускает Camus Job, чей файл конфигурации jar и свойств я поместил в

0зной

1ответ

Загрузка журналов сервера apache в HDFS с использованием Kafka

Я хочу загрузить журналы сервера apache в hdfs с помощью Kafka. создания темы: ./kafka-topics.sh --create --zookeeper 10.25.3.207:2181 --replication-фактор 1 --partitions 1 --topic lognew хвостовых ка

0зной

1ответ

Как разрешить NoClassDefFoundError при использовании Hadoop?

Я получаю Exception in thread "main" java.lang.NoClassDefFoundError: com/linkedin/camus/etl/IEtlKey. На выполнении команды: hadoop jar camus-etl-kafka-0.1.0-SNAPSHOT.jar com.linkedin.camus.etl.kafka.