THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
private val reportAtMinIsrPartitionsOpt = parser.accepts("at-min-isr-partitions",
"if set when describing topics, only show partitions whose isr count is equal to the configured minimum. Not supported with the --zookeeper option.")
private def hasAtMinIsrPartitions(partitionDescription: PartitionDescription) = {
partitionDescription.isr.size == partitionDescription.minIsrCount
}
private def shouldPrintAtMinIsrPartitions(partitionDescription: PartitionDescription) = {
opts.reportAtMinIsrPartitions && hasAtMinIsrPartitions(partitionDescription)
}
# Some other minor changes omitted |
...