[ https://issues.apache.org/jira/browse/MINIFICPP-1374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Gabor Gyimesi reassigned MINIFICPP-1374: ---------------------------------------- Assignee: Gabor Gyimesi (was: Adam Hunyadi) > Implement security protocol support for ConsumeKafka > ---------------------------------------------------- > > Key: MINIFICPP-1374 > URL: https://issues.apache.org/jira/browse/MINIFICPP-1374 > Project: Apache NiFi MiNiFi C++ > Issue Type: Sub-task > Affects Versions: 0.7.0 > Reporter: Adam Hunyadi > Assignee: Gabor Gyimesi > Priority: Major > Fix For: 1.0.0 > > > *Acceptance Criteria:* > SSL: > {code:python|title=Example feature definition} > Scenario Outline: ConsumeKafka receives data via SSL > Given a ConsumeKafka processor set up in a "kafka-consumer-flow" flow > And ssl certificates are placed in "/tmp/resources" with cert name > "cert.pem" and key name "key.pem" > And these processor properties are set: > | processor name | property name | property value | > | ConsumeKafka | Kafka Brokers | kafka-broker:9093 | > | ConsumeKafka | Security Protocol | ssl | > | ConsumeKafka | Security CA | ... | > | ConsumeKafka | Security Cert | ... | > And a PutFile processor with the "Directory" property set to "/tmp/output" > in the "kafka-consumer-flow" flow > And the "success" relationship of the ConsumeKafka processor is connected > to the PutFile > And a kafka broker "broker" set up to communicate via SSL is set up in > correspondence with the third-party kafka publisher > When all instances start up > And a message with content "Alice's Adventures in Wonderland" is published > to the "ConsumeKafkaTest" topic using an ssl connection > And a message with content "Lewis Carroll" is published to the > "ConsumeKafkaTest" topic using an ssl connection > Then two flowfiles with the contents "Alice's Adventures in Wonderland" and > "Lewis Carroll" are placed in the monitored directory in less than 45 seconds > {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)