You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by cm...@apache.org on 2022/09/29 16:17:27 UTC
[kafka] branch trunk updated (d62a42df2e2 -> b9da249bdfa)
This is an automated email from the ASF dual-hosted git repository.
cmccabe pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from d62a42df2e2 KAFKA-10199: Integrate Topology Pause/Resume with StateUpdater (#12659)
add ba89eaf0d7f KAFKA-14265: Prefix ACLs may shadow other prefix ACLs
add fc786c335c6 add unit and integration tests
new b9da249bdfa fix test
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../kafka/api/AuthorizerIntegrationTest.scala | 14 +++++-
.../authorizer/StandardAuthorizerData.java | 55 +++++++++++++++++-----
.../authorizer/StandardAuthorizerTest.java | 27 +++++++++++
3 files changed, 83 insertions(+), 13 deletions(-)
[kafka] 01/01: fix test
Posted by cm...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
cmccabe pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
commit b9da249bdfa9df7a511284d815af8200ab0dfbd9
Author: Colin P. McCabe <cm...@apache.org>
AuthorDate: Thu Sep 29 09:17:03 2022 -0700
fix test
---
.../test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
diff --git a/core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala b/core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala
index d6f736055b2..ff1b2f5934d 100644
--- a/core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala
+++ b/core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala
@@ -2628,8 +2628,7 @@ class AuthorizerIntegrationTest extends BaseRequestTest {
new ResourcePattern(TOPIC, "fooa", PREFIXED))
addAndVerifyAcls(Set(new AccessControlEntry("User:otherPrincipal", WildcardHost, CREATE, ALLOW)),
new ResourcePattern(TOPIC, "foob", PREFIXED))
- val future = createAdminClient().createTopics(Collections.
- singletonList(new NewTopic("foobar", 1, 1.toShort))).all()
- JTestUtils.assertFutureThrows(future, classOf[TopicAuthorizationException])
+ createAdminClient().createTopics(Collections.
+ singletonList(new NewTopic("foobar", 1, 1.toShort))).all().get()
}
}