问题：今天在测试环境发现，各服务能收到canal的通知，但是没有影响的数据内容。开始以为是应用程序问题，排查后发现有多个应该都是这个情况。所以怀疑是canal问题。先说一下系统的实现情况：mysql---(binlog)--->canal------>canal消费端---->kafka----->应用程序消费数据处理步骤：1、查询canal的日志（canal有两个日志，一

现象：测试环境用Docker部署了Nacos2.0版本作为配置中心和服务注册中心。今天测试反馈，服务在调用时时通时不通，https://blog.csdn.net/Alfalfa99/article/details/108042109

人事信息管理系统中，需要管理用户的个人身份照片。通常这种格式的照片只有几 K 到几十 K 大小，保存在数据库中易于进行管理和维护（如果放在文件夹下容易发生误操作而引起数据被修改或丢失）。 功能设计： 给用户提供一个上传的界面，并设定上传文件的尺寸上限。用户上传的照片先统一保存在一个临时文件夹中，之后可以用指向临时文件夹中的这个图片，让用户可以预览自己上传的照片。当所有的用户信息都收集完

1、前提项目中使用了spring-kafka1.3版本，也用了2.5版本。但是对于offset的提交时机是模糊的，这次通过源码分析和资料进一步明确。2、认识KafkaConsumer的偏移量KafkaConsumer是kafka客户端一个入口，通过KafkaConsumer可以拉取kafka服务上的数据、发送心跳包、上报消费分区的偏移量（offset）。为了保证调用KafkaConsumer.po

phoenix中的命名空间可以类似于Mysql中的库名。默认情况下，所创建的表都是在默认的命名空间中。1、启用名称空间映射参数1）phoenix.schema.isNamespaceMappingEnabled：默认false,如果启用了它，那么使用模式创建的表将映射到名称空间。这需要在客户端和服务器端同时设置。如果设置一次，则不应回滚。启用此属性后，旧客户端将无法工作。2）phoenix.sch

1、什么是Query Server1）先认识一下Phoenix重客户端架构在重客户端中，业务代码调用Phoenix提供的API，Phoenix将SQL转换为Hbase中API，再通过Hbase的客户端调用Hbase的服务，完成数据读写。通过这个图我们也可以看到，Phoenix的核心功能都是在RegionServer上执行，将处理下推到服务端，以致在大数据情况下查询速度在毫秒级别。这样的一个架构，业

实现KafkaDeserializationSchema解决Flink中对kafka消息反序列化问题