public class ZKTopicMetadataCollectorConfig extends Object
Modifier and Type | Field and Description |
---|---|
String |
destTopic |
int |
maxNumTopicsProcess |
int |
maxTopicsInSnapshot |
int |
maxZkRequestPerSec |
int |
snapshotInitDelaySec |
int |
snapshotIntervalSec |
Constructor and Description |
---|
ZKTopicMetadataCollectorConfig(int snapshotInitDelaySec,
int snapshotIntervalSec,
int maxTopicsInSnapshot,
int maxZkRequestPerSec,
int maxNumTopicsProcess,
String destTopic) |
ZKTopicMetadataCollectorConfig(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 ZKTopicMetadataCollectorConfig(kafka.server.KafkaConfig kafkaConfig)
public ZKTopicMetadataCollectorConfig(int snapshotInitDelaySec, int snapshotIntervalSec, int maxTopicsInSnapshot, int maxZkRequestPerSec, int maxNumTopicsProcess, String destTopic)