Repository: kafka Updated Branches: refs/heads/trunk d9a455243 -> 370ce2b4b
KAFKA-2815: Fix KafkaStreamingPartitionAssignorTest.testSubscription Fails when order of elements is incorrect Author: Grant Henke <[email protected]> Reviewers: Yasuhiro Matsuda Closes #510 from granthenke/streams-test Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/370ce2b4 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/370ce2b4 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/370ce2b4 Branch: refs/heads/trunk Commit: 370ce2b4b73b60ca52a4fbce246f3fd87b8dbf85 Parents: d9a4552 Author: Grant Henke <[email protected]> Authored: Thu Nov 12 09:59:47 2015 -0800 Committer: Guozhang Wang <[email protected]> Committed: Thu Nov 12 09:59:47 2015 -0800 ---------------------------------------------------------------------- .../processor/internals/KafkaStreamingPartitionAssignorTest.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/370ce2b4/streams/src/test/java/org/apache/kafka/streams/processor/internals/KafkaStreamingPartitionAssignorTest.java ---------------------------------------------------------------------- diff --git a/streams/src/test/java/org/apache/kafka/streams/processor/internals/KafkaStreamingPartitionAssignorTest.java b/streams/src/test/java/org/apache/kafka/streams/processor/internals/KafkaStreamingPartitionAssignorTest.java index 86434fb..c0df2e7 100644 --- a/streams/src/test/java/org/apache/kafka/streams/processor/internals/KafkaStreamingPartitionAssignorTest.java +++ b/streams/src/test/java/org/apache/kafka/streams/processor/internals/KafkaStreamingPartitionAssignorTest.java @@ -171,6 +171,7 @@ public class KafkaStreamingPartitionAssignorTest { PartitionAssignor.Subscription subscription = partitionAssignor.subscription(Utils.mkSet("topic1", "topic2")); + Collections.sort(subscription.topics()); assertEquals(Utils.mkList("topic1", "topic2"), subscription.topics()); Set<TaskId> standbyTasks = new HashSet<>(cachedTasks);
