This is an automated email from the ASF dual-hosted git repository.
martinzink pushed a commit to branch fix_kinesis_feature
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git
The following commit(s) were added to refs/heads/fix_kinesis_feature by this
push:
new 2cd2c377d fix consume_kafka.feature
2cd2c377d is described below
commit 2cd2c377d394101b9e75d499c2525787f6af46d8
Author: Martin Zink <[email protected]>
AuthorDate: Sat Jul 12 21:03:00 2025 +0200
fix consume_kafka.feature
---
docker/test/integration/features/consume_kafka.feature | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/docker/test/integration/features/consume_kafka.feature
b/docker/test/integration/features/consume_kafka.feature
index cddb29f8f..176339edc 100644
--- a/docker/test/integration/features/consume_kafka.feature
+++ b/docker/test/integration/features/consume_kafka.feature
@@ -304,7 +304,8 @@ Feature: Receiving data from using Kafka streaming platform
using ConsumeKafka
Then exactly these flowfiles are in the monitored directory's "processed"
subdirectory in less than 15 seconds: "<contents_after_tiberius>"
And exactly these flowfiles are in the monitored directory's "committed"
subdirectory in less than 15 seconds: "<contents_after_tiberius>"
- When a message with content "Caligula" is published to the
"ConsumeKafkaTest" topic
+ When "kafka-consumer-flow" flow is stopped
+ And a message with content "Caligula" is published to the
"ConsumeKafkaTest" topic
Then exactly these flowfiles are in the monitored directory's "processed"
subdirectory in less than 15 seconds: "<contents_after_caligula>"
When a message with content "Claudius" is published to the
"ConsumeKafkaTest" topic
