camus-sweeper-cdh

＃什么？ 采用 Camus Sweeper 项目（）与 Camus（）一起解决小文件问题 Camus Sweeper 将每小时文件聚合为每日 Avro 文件 Camus Sweeper 需要 Avro-Schema 文件。 由于我没有 Schema Registry，我为此添加了一个配置参数： # define the topic to schema class mappings here # f.e. for topic eu_fakod_app_search_term you should configure: eu_fakod_app_search_term.camus.sweeper.avro.schema.class=eu.fakod.app.search.term.SchemaClass #更多信息