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