Kafka message consumption based on a template within time range

[alexaladin]

There is a Step in Kafka plugin that sounds like
When I wait with $timeout timeout until count of consumed Kafka messages is $comparisonRule $expectedCount

In application under test there is a validation step that evaluates the POST request sent to generate kafka message.
in case of successful validation a massage is being created. IF validation fails a message should not be created.

I need a step similar to the one above that checks if there are messages created in kafka topic that matches particular template
It should be aligned with scenario below (new step functionality is described in point 3)

1. connect to kafka topic to consume messages - there is a separate step for that

2. perform some action to generate a request - e.g. API request

3. Vividus checks if there are messages in kafka topic that match predefined sample;
   a) when we expect e.g. >=5 messages the step should be completed once at least 5 messages are found (PASSED) OR when wait timeout is over (FAILED)
   b) when we expect 0 messages to be in inserted in kafka topic the step should be completed once the message is found (FAILED) OR when wait timeout is over and there is no any message found (PASSED)
   c) messages found should be saved into a variable. So the variable contains a list of messages that match predefined template AND were consumed after connection to kafka topic was established

4. stop consuming messages from kafka

Ideal solution:
When I wait with $timeout timeout until count of consumed Kafka messages matching $template is $comparisonRule $expectedCount

Alternative (limited) solution:
if using step "When I wait with $timeout timeout until count of consumed Kafka messages is $comparisonRule $expectedCount" for the case when 0 messages are expected to be inserted, vividus should wait for $timeout checking if there are any messages are being inserted to kafka topic