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