You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@nifi.apache.org by "Gabor Gyimesi (Jira)" <ji...@apache.org> on 2021/07/21 15:37:00 UTC
[jira] [Updated] (MINIFICPP-1374) Implement security protocol
support for ConsumeKafka
[ https://issues.apache.org/jira/browse/MINIFICPP-1374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Gabor Gyimesi updated MINIFICPP-1374:
-------------------------------------
Status: Patch Available (was: In Progress)
> 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
>
> Time Spent: 20m
> Remaining Estimate: 0h
>
> *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)