You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by jo...@apache.org on 2016/11/15 21:31:18 UTC
nifi git commit: NIFI-3043 Fixing Kafka unit test failures
Repository: nifi
Updated Branches:
refs/heads/master fe59b3415 -> 2614b8354
NIFI-3043 Fixing Kafka unit test failures
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/2614b835
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/2614b835
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/2614b835
Branch: refs/heads/master
Commit: 2614b8354319a9b54264d26b072eb8ef340fd9b8
Parents: fe59b34
Author: jpercivall <JP...@apache.org>
Authored: Tue Nov 15 16:21:24 2016 -0500
Committer: joewitt <jo...@apache.org>
Committed: Tue Nov 15 16:31:10 2016 -0500
----------------------------------------------------------------------
.../org/apache/nifi/processors/kafka/pubsub/ConsumeKafkaTest.java | 2 +-
.../org/apache/nifi/processors/kafka/pubsub/ConsumeKafkaTest.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/nifi/blob/2614b835/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafkaTest.java
----------------------------------------------------------------------
diff --git a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafkaTest.java b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafkaTest.java
index 6fd9053..9a74c44 100644
--- a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafkaTest.java
+++ b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafkaTest.java
@@ -82,7 +82,7 @@ public class ConsumeKafkaTest {
runner.assertValid();
fail();
} catch (AssertionError e) {
- assertTrue(e.getMessage().contains("invalid because group.id is required"));
+ assertTrue(e.getMessage().contains("invalid because Group ID is required"));
}
runner.setProperty(ConsumeKafka_0_10.GROUP_ID, "");
http://git-wip-us.apache.org/repos/asf/nifi/blob/2614b835/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafkaTest.java
----------------------------------------------------------------------
diff --git a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafkaTest.java b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafkaTest.java
index 8e3fa3b..f6febd2 100644
--- a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafkaTest.java
+++ b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafkaTest.java
@@ -82,7 +82,7 @@ public class ConsumeKafkaTest {
runner.assertValid();
fail();
} catch (AssertionError e) {
- assertTrue(e.getMessage().contains("invalid because group.id is required"));
+ assertTrue(e.getMessage().contains("invalid because Group ID is required"));
}
runner.setProperty(ConsumeKafka.GROUP_ID, "");