240 发简信
IP属地:福建
  • Scala学习笔记2

    函数 def关键字定义函数 函数可以有默认值,调用时不传承则为默认值 函数可以省略return 返回类型可以自动推导 如果函数体只有一行,可以省...

  • Scala学习笔记1

    本文的目标在于帮助熟悉Java的同学可以快速掌握Scala的特殊语法 HelloWorld object关键字用于定义Scala的伴生对象,伴生...

  • Kafka常用运维命令

    Topic相关操作 需要注意删除topic时要保证该topic没有被其他消费者消费 按group查看延迟 结果如下: 重置group的offse...

  • Resize,w 360,h 240
    Maven项目对接jenkins与sonar

    增加插件assembly,将项目打包为zip包 在pom.xml中增加如下配置 在src/main/resources下增加如下配置 这个配置适...

  • Flink Standalone高可用+HDFS高可用

    安装Hdfs 由于Flink Standalone需要依赖Hdfs,因此需要先安装Hdfs,这里使用hadoop 2.6.5 版本进行安装 下载...

  • Flink Application打印业务日志

    背景 flink默认会把所有日志打印到taskexecutor的日志,日志混杂在一起很难排查,并且会越来越大可以通过的以下的方式分割离职并做Ro...

  • kafka鉴权PLAIN策略的自定义扩展

    kafka鉴权PLAIN策略的自定义扩展 官方文档中PLAIN策略不推荐在线上环境使用jaas文件进行用户名密码的配置,但如何进行扩展讲的不是很...

  • kafka配置SASL/PLAIN与权限管理调研

    kafka配置SASL/PLAIN与权限管理调研 配置SASL鉴权 配置kafka_server_jaas.conf配置文件 修改服务端配置 修...

  • kafka单机安装&配置安全证书

    kafka单机安装&配置安全证书 单机kafka安装 下载安装包 修改配置启动Kafka 创建topic测试一下生产消费数据 安全证书配置 SS...