Почему я не могу подключить приложение Siddhi для защиты Kafka?

Question

Я создаю и среду с Сиддхи и Кафкой. Без безопасности они работали, и теперь я хочу развернуть его с помощью безопасной Кафки. Для этого я следовал руководству. Logstash (если вы не знаете, что это такое, это еще один производитель / потребитель Kafka), и он правильно подключается к безопасному Kafka. Но когда я создаю приложение siddhi и присваиваю ему свойства, оно всегда ошибочно, и я не могу его развернуть.

The wso2 editor error: Failed to create kafka consumer.

Я попытался без установки security.protocol (потому что я думаю, что проблема связана с ним), и это также не удалось. Независимо от того, положил ли я это / внутри 'option.configuration', я все равно не могу заставить его работать.

Я пытался изменить клиентский ключ / хранилище доверенных сертификатов с сервером, но не сработало.

Мой код приложения это:

@App:name('ConnectKafkaAndSiddhiTest')
@App:description('Description of the plan')
@source(type = 'kafka', bootstrap.servers = "XXX.XXX.XXX.XXX:9093", 
 topic.list = "securityCorrelation", 
 group.id = "test-group", 
 threading.option = "single.thread", 
 seq.enabled = "true", 
 optional.configuration = "security.protocol: SSL,
  ssl.truststore.location:'/home/certificates/KafkaClientSSLTruststore.jks',
  ssl.truststore.password:xxxxxx,
  ssl.keystore.location:'/home/certificates/KafkaClientSSLKeystore.jks',
  ssl.keystore.password:xxxxxxxx,
  ssl.key.password:xxxxxxxxx,
  ssl.endpoint.identification.algorithm:",
@map(type = 'json'))   
@sink(type = 'log')
define stream torList (ip string, foo string);

Я ожидаю, что все сообщения kafka_topic в консоли.