安装chronograf来使用UI对InfluxDB进行操作
安装chronograf来使用UI对InfluxDB进行操作
安装Oracle的jdk8
1 | wget https://s3.cn-north-1.amazonaws.com.cn/tfssa/packages/oracle-java/oracle-java8-jdk_8u181_amd64.deb |
如何依赖不满足
1 | sudo apt-get install -f |
如果依赖的包找不到,可以尝试
1 | sudo mv /etc/apt/sources.list.d/backports.list /etc/apt/sources.list.d/backports.list.bak |
选择使用rpm或者apt-get来安装java-8-oracle,这时的配置将会在 /etc/profile.d/jdk.sh 中
1 | cat /etc/profile.d/jdk.sh |
Flink自带Exactly Once语义,对于支持事务的存储,可以做到数据的不重不丢。
当使用Flink来写hdfs的时候,因为hdfs文件只能在末尾进行append,如果要做到数据不重不丢,hdfs在2.7.0及其以上的版本中提供了truncate功能,可以根据valid-length长度对hdfs文件中的无效数据进行截断操作,从而保证数据不重复。
关于hdfs的truncate功能可以参考:HDFS Truncate文件截断
kafka connect是kafka提供的一个用于在kafka和其他数据系统之间传输数据的工具
1 | https://kafka.apache.org/documentation/#connect |
1 | https://docs.confluent.io/platform/current/connect/concepts.html |
Connectors定义了数据是如何拷贝进kafka以及如何复制出kafka的
包含2种形式的connector,source connector和sink connector
spring-boot-configuration-processor的作用是生成配置的元数据信息,即META-INF目录下的spring-configuration-metadata.json文件,从而告诉spring这个jar包中有哪些自定义的配置
1.其中spring-configuration-metadata.json文件是在编译的时候自动生成的
2.还可以在resources目录下手动添加META-INF/additional-spring-configuration-metadata.json文件,这个文件是手动添加的,用于对spring-configuration-metadata.json进行补充,编译后会合并到spring-configuration-metadata.json中
schema registry是confluent公司开发的一个集中式管理和验证kafka消息schema的组件。官方网站如下
1 | https://docs.confluent.io/platform/current/schema-registry/index.html |
其支持3种格式的schema:JSON,AVRO和protobuf
docker镜像地址如下
1 | https://hub.docker.com/r/confluentinc/cp-schema-registry |
其提供了schema registry的后端服务,提供API用于管理,验证和存储schema,保证了kafka的生产者和消费者可以使用schema来保证数据的一致性和兼容性。
有开源的schema registry前端UI,比如
schema-registry-ui,只支持AVRO的schema
1 | https://hub.docker.com/r/landoop/schema-registry-ui/ |
kafka-ui,支持JSON,AVRO和protobuf(pb嵌套schema需要等0.8版本发布)格式的schema
1 | https://hub.docker.com/r/provectuslabs/kafka-ui |
1.OpenTSDB CLI,参考
1 | https://www.docs4dev.com/docs/zh/opentsdb/2.3/reference/user_guide-cli-index.html |