We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 228b325 commit 2a073a1Copy full SHA for 2a073a1
core/src/main/scala/kafka/zk/KafkaZkClient.scala
@@ -45,10 +45,6 @@ import java.lang.{Long => JLong}
45
import scala.collection.{Map, Seq, mutable}
46
import scala.jdk.CollectionConverters._
47
48
-sealed trait KRaftRegistrationResult
49
-case class FailedRegistrationResult() extends KRaftRegistrationResult
50
-case class SuccessfulRegistrationResult(zkControllerEpoch: Int, controllerEpochZkVersion: Int) extends KRaftRegistrationResult
51
-
52
/**
53
* Provides higher level Kafka-specific operations on top of the pipelined [[kafka.zookeeper.ZooKeeperClient]].
54
*
0 commit comments