public class ZKMetadataCollectorConfig extends Object
Modifier and Type | Field and Description |
---|---|
String |
destTopic |
boolean |
fullConfigsEnable |
int |
maxBytesInSnapshot |
int |
maxNumTopicsProcess |
int |
maxZkRequestPerSec |
int |
snapshotInitDelaySec |
int |
snapshotIntervalSec |
Constructor and Description |
---|
ZKMetadataCollectorConfig(boolean fullConfigsEnable,
int snapshotInitDelaySec,
int snapshotIntervalSec,
int maxBytesInSnapshot,
int maxZkRequestPerSec,
int maxNumTopicsProcess,
String destTopic) |
ZKMetadataCollectorConfig(kafka.server.KafkaConfig kafkaConfig) |
public final boolean fullConfigsEnable
public final int snapshotInitDelaySec
public final int snapshotIntervalSec
public final int maxBytesInSnapshot
public final int maxZkRequestPerSec
public final int maxNumTopicsProcess
public final String destTopic
public ZKMetadataCollectorConfig(kafka.server.KafkaConfig kafkaConfig)
public ZKMetadataCollectorConfig(boolean fullConfigsEnable, int snapshotInitDelaySec, int snapshotIntervalSec, int maxBytesInSnapshot, int maxZkRequestPerSec, int maxNumTopicsProcess, String destTopic)