来自KAFKA KRB5 Kerberos问题的FLINK流
我正在尝试使用https://ci.apache.org/projects/flink/flink-docs-stable/dev/connectors/kafka.html从flink kafkaconsumer流式传输数据
在这里，我的KAFKA是Kerberos安全的，并且启用了SSL。
Caused by: org.apache.kafka.common.errors.SaslAuthenticationException:
Failed to create SaslClient with mechanism GSSAPI
Caused by: javax.security.sasl.SaslException: Failure to initialize
security context [Caused by GSSException: Invalid name provided (Mechanism
level: KrbException: Cannot locate default realm)]
env.java.opts.jobmanager: -Djava.security.krb5.conf=/path/krb5.conf
env.java.opts.taskmanager: -Djava.security.krb5.conf=/path/krb5.conf
我该如何解决这件事？有没有别的办法通过KRB5？
共有1个答案
已经发送了目录conf/using--yarn-ship。此conf文件夹中包含krb5.conf
最后当我用相对路径从flink-conf.yaml传递它时。如下文所示：
jobManager：-djava.security.krb5.conf=./conf/krb5.conf env.java.opts.taskManager：-djava.security.krb5.conf=./conf/krb5.conf env.java.opts:-djava.security.krb5.conf=./conf/krb5.conf
其他的选项-YD对我不起作用。
-
一旦水印到达时间戳，计时器就会触发 问题是：如果结束记录在先，然后基于逻辑，它不会更新骑行状态（相关键），然后2小时后触发，然后它不会收集，不会发出记录，但是如果这个记录符合我们的要求呢？==>记录开始时间发生在2个多小时前？我认为应该有更多的逻辑来处理这件事
-
我是编程新手，我正在尝试制作一个小应用程序，需要将值复制并粘贴到“样式化”excel woorksheet，但在测试第一个命令时，我遇到了第一个问题： 当我从“worksheet1”中获取一个单元格值并将其粘贴到同一工作表（“worksheet1”）中的一个空单元格中时，工作表有点混乱（只是边框单元格消失），这并不好，因为该表将要打印，我需要这些边框单元格保留。 我制作了一个关于这个问题的视频：h
-
是否可以从Flink流作业触发检查点？ 我的用例是：我有两个流R和S要用滚动的时间窗口连接。来源是Kafka。我使用事件时间处理和BoundedOutOfOrdernessGenerator来确保来自两个流的事件最终出现在同一个窗口中。
-
我有一个flink作业（scala），它基本上是从Kafka主题（1.0）读取数据，聚合数据（1分钟事件时间翻转窗口，使用折叠函数，我知道这是不推荐的，但比聚合函数更容易实现），并将结果写入两个不同的Kafka主题。 问题是——当我使用FS状态后端时，一切都运行顺利，检查点需要1-2秒，平均状态大小为200 mb——也就是说，直到状态大小增加（例如，在缩小差距的同时）。 我想我会尝试使用rocks
-
我正在编写一个具有交叉源配置的API 我的websecurity配置有 控制器类 身份验证过滤器检查 匹配。匹配总是变假 我是不是漏掉了什么？ 我添加了什么额外的参数吗？ 期待着迅速的回应。
-
我对Jmete有点陌生，我正在尝试在Jmete上做一个简单的SOAP/XML-RPC请求。我使用了我在互联网上找到的一个示例代码，看起来工作得很好（至少在Chrome使用Wizlet似乎没有问题），但是当我使用在Jmete中的元素上生成插件的肥皂请求时……那就不同了。如果有人能告诉我这个问题，那就太棒了。 这是WSDL的代码： 这是我发送的请求和响应错误。 网址：http://localhost: