Flink记录一次Flink消费kafka写入Elastic在kerberos认证的情况下不消费问题
Posted 九师兄
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Flink记录一次Flink消费kafka写入Elastic在kerberos认证的情况下不消费问题相关的知识,希望对你有一定的参考价值。
文章目录
哎 要放假了,我真的是心在曹营 身在汉,很想回家了,肿么办无心学习,指向跑路。
5Lmd5biI5YWE5ZSv5LiA5Y6f5Yib
哎 要放假了,我真的是心在曹营 身在汉,很想回家了,肿么办无心学习,指向跑路。
5Lmd5biI5YWE5ZSv5LiA5Y6f5Yib
哎 要放假了,我真的是心在曹营 身在汉,很想回家了,肿么办无心学习,指向跑路。
1.概述
最近在做Flink读取kafka写入到kerberos认证的Elastic,但是却发现kafka无法消费的情况。先说说我们的环境
flink节点
node1
flink目录
keytab目录
jaas.conf
es.keytab
然后我们分发文件到其他的机器
hdfs dananode节点
node2
keytab目录
jaas.conf
es
以上是关于Flink记录一次Flink消费kafka写入Elastic在kerberos认证的情况下不消费问题的主要内容,如果未能解决你的问题,请参考以下文章
记录一次Flink消费Kafka空转,无法拉取消息,checkpoint也能成功,但是位置点却不提交的异常处理