阿里云文档 2024-09-12

使用Kafka连接器进行Kerberos身份认证

Kerberos是一种网络身份验证协议,用于提供安全的身份验证服务,以保证通信的安全性。只有在Flink开发控制台正确配置Kerberos和Kafka服务的信息,Flink作业才能访问开启Kerberos认证服务的Kafka集群。本文为您介绍如何为Kafka客户端开启Kerberos认证。

文章 2022-11-26 来自:开发者社区

flink 读取kafka 写入带kerberos认证的hive环境

1:pom.xml引依赖引入<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLoca...

问答 2022-11-23 来自:开发者社区

有大佬知道flink跨Kafka 集群的kerberos 认证是怎么做的吗?

有大佬知道flink跨Kafka 集群的kerberos 认证是怎么做的吗?

问答 2020-10-15 来自:开发者社区

flink 添加kafka的kerberos认证,一直报错,请大佬帮忙看下

org.apache.flink.client.program.ProgramInvocationException: Could not retrieve the execution result. (JobID: 6ccea31b5fa26415bd039f39859f2) at org.apache.flink.client.program.rest.RestClusterClient.s....

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注