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消费并统计结果写入Kafka

记录一次Flink消费Kafka空转,无法拉取消息,checkpoint也能成功,但是位置点却不提交的异常处理

flink写入hdfs

记flink checkpoint 无法写入问题

FlinkFlink Kafka 消费卡死 消费组卡死 topic无写入 实际有数据 topic正常

flink自定义metrics监控kafka消费