From c8d0b88fa66ba5bde52feacd70d025e073362f05 Mon Sep 17 00:00:00 2001 From: Ashish Singh Date: Wed, 22 Jun 2016 13:19:08 -0700 Subject: [PATCH] MINOR: Verify acls for group resource on all servers of test cluster. --- .../scala/integration/kafka/api/EndToEndAuthorizationTest.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/test/scala/integration/kafka/api/EndToEndAuthorizationTest.scala b/core/src/test/scala/integration/kafka/api/EndToEndAuthorizationTest.scala index 05d8dc54fd5f3..8edb6f85aa89f 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")