qs（1）siddhi应用程序是否支持使用sasl\u ssl协议和plain as sasl机制连接到kafka。qs（2）如果没有什么sasl选项可用。我使用的是wso2流处理器4.4。
下面是一个简单的程序，它可以读取Kafka主题，并按照服务器控制台上的方式编写内容。
注1：连接建立得很好（在工作节点上的部署也很成功）。但控制台上什么也没反映出来。
note:2：如果连接到不安全的kafka群集，程序运行正常（我删除optional.configuration并适当更改bootstrap servers值）

@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;