Backquarter (Kafka Message Synchronization) 同步Ucloud上的Kafka消息到IDC机房:消费者消费Ucloud上Kafka集群的消息,生成文件,实时同步文件至IDC机房。生产者实时监控文件,解析文件发送至IDC的Kafka集群。 说明 src/java: 程序源码 src/resources: 配置文件 Consumer.java: 消费者 ProducerFromFile.java: 生产者 脚本 script/snappy_file.py: 文件压缩/解压脚本 script/synch_file.py: 文件传输脚本