Java bug搬运工，小数据攻城狮^O^
发简信
IP属地：福建
-
Scala学习笔记2
函数 def关键字定义函数 函数可以有默认值，调用时不传承则为默认值 函数可以省略return 返回类型可以自动推导 如果函数体只有一行，可以省略挎号 匿名函数赋予变量 变量...
-
Scala学习笔记1
本文的目标在于帮助熟悉Java的同学可以快速掌握Scala的特殊语法 HelloWorld object关键字用于定义Scala的伴生对象，伴生对象类似于java的静态类，用...
-
Kafka常用运维命令
Topic相关操作 需要注意删除topic时要保证该topic没有被其他消费者消费 按group查看延迟 结果如下： 重置group的offset 由于Kafka内部零拷贝的...
-
Maven项目对接jenkins与sonar增加插件assembly，将项目打包为zip包 在pom.xml中增加如下配置 在src/main/resources下增加如下配置 这个配置适用于当前的springboot...
-
Flink Standalone高可用+HDFS高可用
安装Hdfs 由于Flink Standalone需要依赖Hdfs，因此需要先安装Hdfs，这里使用hadoop 2.6.5 版本进行安装 下载依赖包 flink 依赖包：h...
-
Flink Application打印业务日志
背景 flink默认会把所有日志打印到taskexecutor的日志，日志混杂在一起很难排查，并且会越来越大可以通过的以下的方式分割离职并做Rolling 添加依赖jar包 ...
-
本博客所有内容均适用知识共享-署名-相同方式共享（CC-BY-SA）4.0协议。
-
kafka鉴权PLAIN策略的自定义扩展
kafka鉴权PLAIN策略的自定义扩展 官方文档中PLAIN策略不推荐在线上环境使用jaas文件进行用户名密码的配置，但如何进行扩展讲的不是很清楚，这里记录下具体的实践过程...
-
kafka配置SASL/PLAIN与权限管理调研
kafka配置SASL/PLAIN与权限管理调研 配置SASL鉴权 配置kafka_server_jaas.conf配置文件 修改服务端配置 修改客户端配置 验证一下 ACL...
-
kafka单机安装&配置安全证书
kafka单机安装&配置安全证书 单机kafka安装 下载安装包 修改配置启动Kafka 创建topic测试一下生产消费数据 安全证书配置 SSL配置 生成证书里面host和...
-
Pulsar ACL配置-JWT策略调研
Pulsar ACL配置-JWT策略调研 broker配置 配置超管生成token 显示如下： 配置普通用户 配置client 运行 常见pulsar命令租户 命名空间 to...
-
Pulsar证书配置
Pulsar证书配置 生成TLS证书 创建授权证书 certs/ca.cert.pem是授权证书的公钥，需要交给客户端进行验证 private/ca.key.pem是授权证书...
-
Pulsar单机安装
Pulsar单机安装 下载安装包 初始化元数据 部署BookKeeper并启动 修改BookKeeper的配置文件 启动 部署 Pulsar brokers 配置Broker...
