勤奋鸵鸟

文章
4
资源
0
加入时间
3年0月21天

Flink解析kafka canal未压平数据为message报错

canal使用非flatmessage方式获取mysql bin log日志发至kafka比直接发送json效率要高很多,数据发到kafka后需要实时解析为json,这里可以使用strom或者flink,公司本来就是使用strom解析,但是在吞吐量上有瓶颈,优化空间不大。所以试一试通过flink来做。非flatmessage需要使用特定的反序列化方式来处理为Message对象,所以这里需要自定...

Redis Sentinel 使用Java测试Sentinel连接

redis的sentinel模式java代码连接测试package com.czxy.demo01;import redis.clients.jedis.Jedis;import redis.clients.jedis.JedisPoolConfig;import redis.clients.jedis.JedisSentinelPool;import java.util.Array...

WPF .NET Core应用程序 简单使用MvvmLight

参考:https://www.cnblogs.com/wzh2010/p/6285990.htmlhttps://www.cnblogs.com/manupstairs/p/13661227.htmlhttp://cn.voidcc.com/question/p-wuerhmow-rw.html一、Models1.StaffModel.csusing GalaSoft.MvvmLight;using System;using System.Collections.Generic;using