- @weixin_43865381
简介
该用户还未填写简介
擅长的技术栈
可提供的服务
暂无可提供的服务
flink可视化控制台依赖配置
首先我跟大家说一下我的遇到的问题，我这边有一台虚拟机服务器的ip地址有人改动了，之前服务器的地址为172.18.2.248，不知道怎么回事，ip地址变为172.18.2.237首先要改动ip,改动的操作如下：首先使用ifconfig的命令看一下，目前你使用的那个网络配置：eno16777736: flags=4163<UP,BROADCAST,RUNNING,MULTICAST> ..
从某一目录下读取文件写入到kafka的代码实现package lm;import java.io.BufferedReader;import java.io.ByteArrayOutputStream;import java.io.File;import java.io.FileInputStream;import java.io.FileNotFoundException;impo...
目录LEO&HW基本概念LEO&HW更新流程LEOHW更新流程示例分析 引言记录下和kafka相关的LEO和HW的内容，文中很多理解参考文末书籍还有某前辈。回到顶部LEO&HW基本概念Base Offset：是起始位移，该副本中第一条消息的offset，如下图，这里的起始位移是0，如果一个日志文件写满1G后（默认1G后会log rolling），这个起始位移就不是
对kafka进行了kerberos认证之后，要topic和用户进行acl授权的操作
java代码实现向有kerberos认证的kafka中发送avro格式数据1.在idea中创建一个maven工程1.1 pom.xml 内容<dependencies><dependency><groupId>org.apache.kafka</groupId><...
关于kafka的topic的授权问题的汇总在具有kerberos的集群上对其他用户相应的topic授权的时候主要有以下几点如果超级用户为kafka这时候需要切换到kafka安装的一个节点上，进行kinit验证的操作例如：kinit –kt /etc/kafka/conf/kafka.keytab kafka需要创建要对topic进行操作的用户（读，写或者读和写都具备）1.1添加的一个普...
有kerberos认证之后的kafka，先进行授权的操作测试集群上的超级用户为kafkakinit -kt /etc/kafka/conf/kafka.keytab kafka首先切换到安装的kafka的目录下，随后可以执行以下命令1、创建topic的命令操作：测试集群上的超级用户为kafkabin/kafka-topics.sh --create --zookeeper local...
Flink Checkpoint超时问题文章目录Flink Checkpoint超时问题问题现象问题分析问题1：TaskManager进程挂掉问题2：任务长时间处于CANCELING问题3：Checkpoint超时问题4：数据无法正常同步解决思路总结参考文档问题现象业务部门最近使用Flink来做数...