写文章
- @Andrew_2018
简介
该用户还未填写简介
擅长的技术栈
未填写擅长的技术栈
可提供的服务
暂无可提供的服务
flink on k8s部署(native)
flink on k8s Application Mode部署
Canal kafka 消费 Caused by: com.google.protobuf.InvalidProtocolBufferException: Protocol message end
在做解析binlog的时候，消费kafka中的binlog信息，在解析时出现了这个异常。解决方法:将canal 配置文件canal.properties里的canal.mq.flatMessage = false ，默认为true当然我这种解决方案是在排除了canal server与client版本不一致，kafka topic里没有其他数据的情况下生效的...
log4j2自定义kafka appender
@Plugin(name = "SelfKafkaAppender", category = "Core", elementType = "appender", printObject = true)public class SelfKafkaAppender extends AbstractAppender {private String topic;private String fileNam
到底了