org.apache.storm.kafka

Class SpoutConfig

java.lang.Object

org.apache.storm.kafka.KafkaConfig

org.apache.storm.kafka.SpoutConfig

All Implemented Interfaces:

java.io.Serializable

public class SpoutConfig
extends KafkaConfig
implements java.io.Serializable

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
java.lang.String	failedMsgRetryManagerClass
java.lang.String	id
java.lang.String	outputStreamId
long	retryDelayMaxMs
double	retryDelayMultiplier
long	retryInitialDelayMs
int	retryLimit
long	stateUpdateIntervalMs
java.lang.Integer	zkPort
java.lang.String	zkRoot
java.util.List<java.lang.String>	zkServers

Fields inherited from class org.apache.storm.kafka.KafkaConfig

bufferSizeBytes, clientId, fetchMaxWait, fetchSizeBytes, hosts, ignoreZkOffsets, maxOffsetBehind, metricsTimeBucketSizeInSecs, minFetchByte, scheme, socketTimeoutMs, startOffsetTime, topic, useStartOffsetTimeIfOffsetOutOfRange

Constructor Summary

Constructors

Constructor and Description
SpoutConfig(BrokerHosts hosts, java.lang.String topic, java.lang.String zkRoot, java.lang.String id)

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

zkServers

public java.util.List<java.lang.String> zkServers

zkPort

public java.lang.Integer zkPort

zkRoot

public java.lang.String zkRoot

id

public java.lang.String id

outputStreamId

public java.lang.String outputStreamId

stateUpdateIntervalMs

public long stateUpdateIntervalMs

failedMsgRetryManagerClass

public java.lang.String failedMsgRetryManagerClass

retryInitialDelayMs

public long retryInitialDelayMs

retryDelayMultiplier

public double retryDelayMultiplier

retryDelayMaxMs

public long retryDelayMaxMs

retryLimit

public int retryLimit

Constructor Detail

SpoutConfig

public SpoutConfig(BrokerHosts hosts,
                   java.lang.String topic,
                   java.lang.String zkRoot,
                   java.lang.String id)