[ https://issues.apache.org/jira/browse/MINIFICPP-1373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Gabor Gyimesi reopened MINIFICPP-1373: -------------------------------------- > Implement and test a simplified ConsumeKafka processor without security > protocols > --------------------------------------------------------------------------------- > > Key: MINIFICPP-1373 > URL: https://issues.apache.org/jira/browse/MINIFICPP-1373 > 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 > > Attachments: ConsumeKafka_test_matrix.numbers, > ConsumeKafka_test_matrix.pdf > > Time Spent: 33h 10m > Remaining Estimate: 0h > > *Acceptance Criteria:* > *{color:#de350b}See attached test matrix plan.{color}* > Additional test (that require multiple Kafka consumers): > {quote}{color:#505f79}*GIVEN*{color} two ConsumeKafkas with > {color:#0747a6}different group ids{color} subscribed to the same topic > {color:#505f79}*WHEN*{color} a message is published to the topic > {color:#505f79}*THEN*{color} both of the ConsumeKafka processors should > produce identical flowfiles > {quote} > {quote}{color:#505f79}*GIVEN*{color} two ConsumeKafkas with > {color:#0747a6}the same group id{color} subscribed to the same topic > {color:#505f79}*WHEN*{color} a message is published to the topic > {color:#505f79}*THEN*{color} only one of the ConsumeKafka processors should > produce a flowfile > {quote} > {quote}{color:#505f79}*GIVEN*{color} two ConsumeKafkas with > {color:#0747a6}the same group id{color} subscribed to the same topic with > exactly two partitions with {color:#0747a6}Offset Reset{color} set to > {color:#0747a6}earliest{color}. > {color:#505f79}*WHEN*{color} a messages were already present on both > partitions and the second one crashes > {color:#505f79}*THEN*{color} the first one should process duplicates of the > messages that originally came to the second (at_least_once delivery) > {quote} > {quote}{color:#505f79}*GIVEN*{color} two ConsumeKafkas with > {color:#0747a6}the same group id{color} subscribed to the same topic with > exactly two partitions with {color:#0747a6}Offset Reset{color} set to > {color:#0747a6}latest{color}. > {color:#505f79}*WHEN a*{color} messages were already present on both > partitions and the second one crashes > {color:#505f79}*THEN*{color} the first one should {color:#0747a6}not{color} > process duplicates of the messages that originally came to the second > (at_most_once delivery) > {quote} > {quote}{color:#505f79}*GIVEN*{color} two ConsumeKafkas with > {color:#0747a6}the same group id{color} subscribed to the same topic with > exactly two partitions with {color:#0747a6}Offset Reset{color} set to > {color:#0747a6}none{color}. > {color:#505f79}*WHEN*{color} a messages were already present on both > partitions and the second one crashes > {color:#505f79}*THEN*{color} the first one should throw an exception > {quote} > *Background:* > See parent task. > *Proposal:* > This should be the first part of the implementation, the second being adding > and testing multiple security protocols. -- This message was sent by Atlassian Jira (v8.3.4#803005)