[MINIFICPP-1374] Implement security protocol support for ConsumeKafka

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.7.0
• Fix Version/s: 1.0.0, 0.11.0
• Assignee: Gábor Gyimesi
• Reporter: Adam Hunyadi
• Created: 15/Sep/20 13:14
• Updated: 14/Sep/21 13:37
• Resolved: 14/Sep/21 13:37

Description

Acceptance Criteria:
SSL:

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