flink-kafka-hbase:功能：实现kafka消息实时落地hbase，支持csvjson字符串两种格式的消息，支持自定义组合rowkey,列簇和列名，支持按照kafka消息流中不同字段join不同的hbase表，并自定义写入列簇和列(join时需评估一下性能)， 支持at least once语义 外部依赖：apollo配置中心，本项目依靠配置驱动，配置存储在apollo配置中心

[{"title":"（ 18 个子文件 35KB ） flink-kafka-hbase:功能：实现kafka消息实时落地hbase，支持csvjson字符串两种格式的消息，支持自定义组合rowkey,列簇和列名，支持按照kafka消息流中不同字段join不同的hbase表，并自定义写入列簇和列(join时需评估一下性能)， 支持at least once语义 外部依赖：apollo配置中心，本项目依靠配置驱动，配置存储在apollo配置中心","children":[{"title":"flink-kafka-hbase-master","children":[{"title":"src","children":[{"title":"main","children":[{"title":"resources","children":[{"title":"logback.xml <span style='color:#111;'> 534B </span>","children":null,"spread":false},{"title":"application.conf <span style='color:#111;'> 40B </span>","children":null,"spread":false}],"spread":true},{"title":"java","children":[{"title":"com","children":[{"title":"singgel","children":[{"title":"bigdata","children":[{"title":"flinksinkhbase","children":[{"title":"config","children":[{"title":"JobConfig.java <span style='color:#111;'> 7.00KB </span>","children":null,"spread":false},{"title":"KafkaConfig.java <span style='color:#111;'> 2.56KB </span>","children":null,"spread":false},{"title":"HbaseConfig.java <span style='color:#111;'> 2.34KB </span>","children":null,"spread":false}],"spread":true},{"title":"HbaseSink.java <span style='color:#111;'> 15.48KB </span>","children":null,"spread":false},{"title":"FlinkRunner.java <span style='color:#111;'> 2.64KB </span>","children":null,"spread":false},{"title":"common","children":[{"title":"HbaseUtil.java <span style='color:#111;'> 5.71KB </span>","children":null,"spread":false},{"title":"CustomJsonDeserializationSchema.java <span style='color:#111;'> 1.77KB </span>","children":null,"spread":false},{"title":"JobConfigManager.java <span style='color:#111;'> 1.79KB </span>","children":null,"spread":false},{"title":"ValueFormat.java <span style='color:#111;'> 247B </span>","children":null,"spread":false},{"title":"JoinTable.java <span style='color:#111;'> 1.57KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"test","children":[{"title":"resources","children":[{"title":"logback.xml <span style='color:#111;'> 1.81KB </span>","children":null,"spread":false}],"spread":true},{"title":"java","children":[{"title":"com","children":[{"title":"singgel","children":[{"title":"bigdata","children":[{"title":"recommend","children":[{"title":"HbaseGetTest.java <span style='color:#111;'> 8.41KB </span>","children":null,"spread":false},{"title":"HbaseByteTest.java <span style='color:#111;'> 746B </span>","children":null,"spread":false},{"title":"JobConfigTest.java <span style='color:#111;'> 9.34KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 4.72KB </span>","children":null,"spread":false},{"title":"README.md <span style='color:#111;'> 26.21KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}]