object
ReplicaVerificationTool
extends Logging
Value Members
-
def
!=
(arg0: AnyRef): Boolean
-
def
!=
(arg0: Any): Boolean
-
def
##
(): Int
-
def
==
(arg0: AnyRef): Boolean
-
def
==
(arg0: Any): Boolean
-
def
asInstanceOf
[T0]
: T0
-
val
clientId
: String
-
def
clone
(): AnyRef
-
val
dateFormat
: SimpleDateFormat
-
val
dateFormatString
: String
-
def
debug
(msg: ⇒ String, e: ⇒ Throwable): Unit
-
def
debug
(e: ⇒ Throwable): Any
-
def
debug
(msg: ⇒ String): Unit
-
def
eq
(arg0: AnyRef): Boolean
-
def
equals
(arg0: Any): Boolean
-
def
error
(msg: ⇒ String, e: ⇒ Throwable): Unit
-
def
error
(e: ⇒ Throwable): Any
-
def
error
(msg: ⇒ String): Unit
-
def
fatal
(msg: ⇒ String, e: ⇒ Throwable): Unit
-
def
fatal
(e: ⇒ Throwable): Any
-
def
fatal
(msg: ⇒ String): Unit
-
def
finalize
(): Unit
-
def
getClass
(): java.lang.Class[_]
-
def
getCurrentTimeString
(): String
-
def
hashCode
(): Int
-
def
info
(msg: ⇒ String, e: ⇒ Throwable): Unit
-
def
info
(e: ⇒ Throwable): Any
-
def
info
(msg: ⇒ String): Unit
-
def
isInstanceOf
[T0]
: Boolean
-
var
logIdent
: String
-
lazy val
logger
: Logger
-
val
loggerName
: String
-
def
main
(args: Array[String]): Unit
-
def
ne
(arg0: AnyRef): Boolean
-
def
notify
(): Unit
-
def
notifyAll
(): Unit
-
def
swallow
(action: ⇒ Unit): Unit
-
def
swallowDebug
(action: ⇒ Unit): Unit
-
def
swallowError
(action: ⇒ Unit): Unit
-
def
swallowInfo
(action: ⇒ Unit): Unit
-
def
swallowTrace
(action: ⇒ Unit): Unit
-
def
swallowWarn
(action: ⇒ Unit): Unit
-
def
synchronized
[T0]
(arg0: ⇒ T0): T0
-
def
toString
(): String
-
def
trace
(msg: ⇒ String, e: ⇒ Throwable): Unit
-
def
trace
(e: ⇒ Throwable): Any
-
def
trace
(msg: ⇒ String): Unit
-
def
wait
(): Unit
-
def
wait
(arg0: Long, arg1: Int): Unit
-
def
wait
(arg0: Long): Unit
-
def
warn
(msg: ⇒ String, e: ⇒ Throwable): Unit
-
def
warn
(e: ⇒ Throwable): Any
-
def
warn
(msg: ⇒ String): Unit
Inherited from AnyRef
Inherited from Any
For verifying the consistency among replicas.
The consistency verification is up to the high watermark. The tool reports the max lag between the verified offset and the high watermark among all partitions.
If a broker goes down, the verification of the partitions on that broker is delayed until the broker is up again.
Caveats: 1. The tools needs all brokers to be up at startup time. 2. The tool doesn't handle out of range offsets.