Move MeituanLogPartitioner to seperate package
Support compress in StringRecordWriterProvider
Add zklock to avoid same job collision
Fix bug. Kill job will not release lock
Code refactor
Support partition adjustment
whitelist topic verify and support user specified target topic
Fix typo
fix for decoding binlog protobuf
Merge branch 'camus-kafka-0.8' of ssh://git.sankuai.com/data/camus into camus-kafka-0.8
Add new feature: Etl reload and deltareload
Add unittest
Add loginfo
Change logic for selecting deltareload start point
Merge branch 'camus-kafka-0.8' of ssh://git.sankuai.com/data/camus into camus-kafka-0.8
Merge branch 'camus-kafka-0.8' of ssh://git.sankuai.com/data/camus into camus-kafka-0.8
Fix dataformat bug.
fix BinlogMessageDecoder
Fix dateformat bug
Merge branch 'camus-kafka-0.8' of ssh://git.sankuai.com/data/camus into camus-kafka-0.8