[
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)
