flink-kafka-hbase
功能：实现kafka消息实时落地hbase，支持csv/json字符串两种格式的消息，支持自定义组合rowkey,列簇和列名，支持按照kafka消息流中不同字段join不同的hbase表，并自定义写入列簇和列(join时需评估一下性能)
支持at least once语义
外部依赖：apollo配置中心，本项目依靠配置驱动，配置存储在apollo配置中心
配置：
{
"indexColumnMapping": { --indexColumnMapping即CSV格式消息的key和value按照value里的分隔符拼接后再分割后下标及写入hbase列的对应关系
"0": "basic:time", --第0列始终是kafka消息的key，如果不需要可以不指定
"1": "basic:user_id",
2023-01-30 14:24:41
35KB
1
SpringBoot整合Apollo(Windows)配置中心及使用
2022-08-19 10:42:16
141.85MB
1
18、分布式配置中心nacos完整源码
参考地址：https://blog.csdn.net/qq23001186/article/details/126083648
- **附录**：资源包含了YApi的json导入，nacos的配置集导入
- user_srv/main.go：健康监查与注册对象的ip地址需要修改为本机的ip地址
2022-07-31 19:05:03
444KB
1
「Java分享客栈」Nacos配置中心称王称霸，我Apollo一生也不弱于人！.doc
2022-07-10 14:05:54
1.16MB
SpringCloudAlibaba注册中心与配置中心之利器Nacos实战与源码分析(下).doc
2022-07-09 09:08:00
3.02MB
wotrd-cloud
基于nacos的spring cloud微服务框架、集成认证授权、动态网关、分库分表、dubbo开箱即用。
个人博客地址：
qq群： 602107221
1、 wotrd-auth： 认证授权服务
2、 wotrd-client： 客户端服务
3、 wotrd-dubbo： dubbo服务注册与发现（添加百度富文本ueditor）
4、 wotrd-dynamic-datasource： 动态数据源、基于xa使用atomikos实现分布式事物
5、 wotrd-feign： nacos服务注册发现、redis、kafka、sentinel、elasticsearch
6、 wotrd-gateway： 动态网关服务
2022-05-09 17:05:06
3.16MB
1