Поддержка SASL в потоковом процессоре WSO2 / Siddhi - PullRequest
Новая
       46

Поддержка SASL в потоковом процессоре WSO2 / Siddhi

0 голосов
/ 06 февраля 2020

Qs (1) Поддерживает ли приложение Siddhi подключение к Kafka с использованием протокола SASL_SSL с PLAIN в качестве механизма SASL. Qs (2) Если нет, какие опции SASL доступны. Я использую потоковый процессор WSO2 4.4.

Ниже приведена простая программа, которая должна читать из топики Kafka c и записывать содержимое в том виде, в котором оно находится на консоли сервера.

Примечание-1: Соединения устанавливаются очень хорошо (Развертывание на рабочем узле также успешно). Но ничего не отражается на консоли.

Примечание: 2: Программа работает нормально, если она подключена к незащищенному кластеру Kafka (я удаляю необязательную конфигурацию и соответствующим образом изменяю значение bootstrap server) 

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