public class SpoutConfig extends KafkaConfig implements Serializable
Modifier and Type | Field and Description |
---|---|
String |
id |
long |
stateUpdateIntervalMs |
Integer |
zkPort |
String |
zkRoot |
List<String> |
zkServers |
bufferSizeBytes, clientId, fetchMaxWait, fetchSizeBytes, forceFromStart, hosts, maxOffsetBehind, metricsTimeBucketSizeInSecs, scheme, socketTimeoutMs, startOffsetTime, topic, useStartOffsetTimeIfOffsetOutOfRange
Constructor and Description |
---|
SpoutConfig(BrokerHosts hosts,
String topic,
String zkRoot,
String id) |
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.