org.apache.storm.kafka

Class SpoutConfig

java.lang.Object

org.apache.storm.kafka.KafkaConfig

org.apache.storm.kafka.SpoutConfig

All Implemented Interfaces:

Serializable

public class SpoutConfig
extends KafkaConfig
implements Serializable

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
String	failedMsgRetryManagerClass
String	id
String	outputStreamId
long	retryDelayMaxMs
double	retryDelayMultiplier
long	retryInitialDelayMs
int	retryLimit
long	stateUpdateIntervalMs
Integer	zkPort
String	zkRoot
List<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, String topic, String zkRoot, String id) Create a SpoutConfig without setting client.id, which can make the source application ambiguous when tracing Kafka calls.
SpoutConfig(BrokerHosts hosts, String topic, String clientId, String zkRoot, String id) Create a SpoutConfig with a client.id value.

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

zkServers

public List<String> zkServers

zkPort

public Integer zkPort

zkRoot

public String zkRoot

id

public String id

outputStreamId

public String outputStreamId

stateUpdateIntervalMs

public long stateUpdateIntervalMs

failedMsgRetryManagerClass

public 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,
                   String topic,
                   String zkRoot,
                   String id)

Create a SpoutConfig without setting client.id, which can make the source application ambiguous when tracing Kafka calls.

SpoutConfig

public SpoutConfig(BrokerHosts hosts,
                   String topic,
                   String clientId,
                   String zkRoot,
                   String id)

Create a SpoutConfig with a client.id value.