Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

KAFKA-18427 Remove ZooKeeperClient #18613

Open
wants to merge 8 commits into
base: trunk
Choose a base branch
from
+0 −269
Open

KAFKA-18427 Remove ZooKeeperClient #18613

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
8 commits
Select commit Hold shift + click to select a range
f581936
remove zkClient in test
m1a2st Jan 18, 2025
8b9af5b
remove zkClient in test
m1a2st Jan 18, 2025
367c02c
remove KafkaZkClient.scala
m1a2st Jan 18, 2025
a0eda03
add ZooKeeperClientException
m1a2st Jan 18, 2025
ead163a
Merge branch 'trunk' into KAFKA-18427
ijuma Jan 19, 2025
b8b9a20
update the license
m1a2st Jan 19, 2025
8315a45
Merge branch 'trunk' into KAFKA-18427
m1a2st Jan 19, 2025
af6a243
remove ZooKeeperClientException.scala
m1a2st Jan 19, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
267 changes: 0 additions & 267 deletions core/src/main/scala/kafka/zookeeper/ZooKeeperClient.scala
View file
Open in desktop

This file was deleted.

2 changes: 0 additions & 2 deletions core/src/test/scala/unit/kafka/security/authorizer/BaseAuthorizerTest.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,6 @@ package kafka.security.authorizer
import java.net.InetAddress
import java.util.UUID
import kafka.server.KafkaConfig
import kafka.zookeeper.ZooKeeperClient
import org.apache.kafka.common.acl.AclOperation.{ALL, READ, WRITE}
import org.apache.kafka.common.acl.AclPermissionType.{ALLOW, DENY}
import org.apache.kafka.common.acl.{AccessControlEntry, AccessControlEntryFilter, AclBinding, AclBindingFilter, AclOperation}
Expand Down Expand Up @@ -50,7 +49,6 @@ trait BaseAuthorizerTest {
val requestContext: RequestContext = newRequestContext(principal, InetAddress.getByName("192.168.0.1"))
val superUserName = "superuser1"
var config: KafkaConfig = _
var zooKeeperClient: ZooKeeperClient = _
var resource: ResourcePattern = _

@Test
Expand Down
Loading