Repository: kafka Updated Branches: refs/heads/trunk 10bbffd75 -> 8bf18df1b
MINOR: Verify acls for group resource on all servers of test cluster. Author: Ashish Singh <[email protected]> Reviewers: Ismael Juma <[email protected]>, Sriharsha Chintalapani <[email protected]> Closes #1540 from SinghAsDev/MinorAclTestCheck Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/8bf18df1 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/8bf18df1 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/8bf18df1 Branch: refs/heads/trunk Commit: 8bf18df1b6584d95a850a846b26046c2b79531b7 Parents: 10bbffd Author: Ashish Singh <[email protected]> Authored: Wed Jun 22 15:26:39 2016 -0700 Committer: Sriharsha Chintalapani <[email protected]> Committed: Wed Jun 22 15:26:39 2016 -0700 ---------------------------------------------------------------------- .../scala/integration/kafka/api/EndToEndAuthorizationTest.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/8bf18df1/core/src/test/scala/integration/kafka/api/EndToEndAuthorizationTest.scala ---------------------------------------------------------------------- diff --git a/core/src/test/scala/integration/kafka/api/EndToEndAuthorizationTest.scala b/core/src/test/scala/integration/kafka/api/EndToEndAuthorizationTest.scala index 05d8dc5..8edb6f8 100644 --- a/core/src/test/scala/integration/kafka/api/EndToEndAuthorizationTest.scala +++ b/core/src/test/scala/integration/kafka/api/EndToEndAuthorizationTest.scala @@ -224,7 +224,7 @@ trait EndToEndAuthorizationTest extends IntegrationTestHarness with SaslSetup { AclCommand.main(groupAclArgs) servers.foreach(s => { TestUtils.waitAndVerifyAcls(TopicWriteAcl ++ TopicDescribeAcl, s.apis.authorizer.get, topicResource) - TestUtils.waitAndVerifyAcls(GroupReadAcl, servers.head.apis.authorizer.get, groupResource) + TestUtils.waitAndVerifyAcls(GroupReadAcl, s.apis.authorizer.get, groupResource) }) //Produce records debug("Starting to send records")
