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)