ssl - WSO2 流处理器 / Siddhi 中的 SASL 支持
问题描述
Qs (1) Siddhi 应用程序是否支持使用以 PLAIN 作为 SASL 机制的 SASL_SSL 协议连接到 Kafka。Qs (2) 如果没有可用的 SASL 选项。我正在使用 WSO2 流处理器 4.4。
下面是一个简单的程序,它可以从 Kafka 主题中读取并在服务器控制台上按原样写入内容。
注1:连接建立得很好(在工作节点上部署也成功)。但控制台上没有任何反映。
注意:2:如果连接到非安全 Kafka 集群,程序运行良好(我删除了 optional.configuration 并适当地更改引导服务器值)
@App:name("SKAppOne")
@source(
type='kafka',
topic.list='skapp1',
group.id='g1',
partition.no.list='0',
threading.option='single.thread',
bootstrap.servers='**KAFKABROKERIP:KAFKABROKERPORT**',
optional.configuration=
***"sasl.mechanism:PLAIN,security.protocol:SASL_SSL,***
sasl.jaas.config:org.apache.kafka.common.security.plain.PlainLoginModule required username='**validuserid**' password='**validpassword**';,
ssl.truststore.location:**validlocationfor_client.truststore.jks file**,
ssl.truststore.password:**validpassword**,
ssl.keystore.location:**validlocationfor_server.keystore.jks file**,
ssl.keystore.password:**validpassword**,
ssl.key.password:**validpassword**",
@map(type='json'))
define stream InputStreamFromSecureKafka (name string, location string);
@sink(type='log')
define stream SOutputStreamToConsole (name string, location string);
@info(name='kafkatosconsole')
from InputStreamFromSecureKafka
select *
insert into SOutputStreamToConsole;
解决方案
推荐阅读
- html - 对齐 div 框 CSS
- flutter - 如何更改以编程方式创建的动画位置小部件的状态?
- c# - 我的 C#/mySql 产品消费查询花费的时间比代码中跟踪的时间长得多
- spring-boot - 记录 SpringBoot 应用对外部服务的请求
- javascript - Vue 应用程序中 Canvas 中的 Three.js 动画无法正确调整大小
- mongodb - 如何将所有 mongo 文档中的值从字符串更新为数组?
- amazon-web-services - 没有 WWW 的域名在 AWS 上不起作用
- python - Python pandas数据框:数据框到另一个数据框
- typescript - TypeScript:使函数参数有条件地可选
- javascript - li 悬停时的内容样式