org.apache.storm.kafka

Class KafkaConfig

java.lang.Object

org.apache.storm.kafka.KafkaConfig

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

SpoutConfig, TridentKafkaConfig

public class KafkaConfig
extends Object
implements Serializable

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
int	bufferSizeBytes
String	clientId
int	fetchMaxWait
int	fetchSizeBytes
BrokerHosts	hosts
boolean	ignoreZkOffsets
long	maxOffsetBehind
int	metricsTimeBucketSizeInSecs
int	minFetchByte
MultiScheme	scheme
int	socketTimeoutMs
long	startOffsetTime
String	topic
boolean	useStartOffsetTimeIfOffsetOutOfRange

Constructor Summary

Constructors

Constructor and Description
KafkaConfig(BrokerHosts hosts, String topic)
KafkaConfig(BrokerHosts hosts, String topic, String clientId)

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

hosts

public final BrokerHosts hosts

topic

public final String topic

clientId

public final String clientId

fetchSizeBytes

public int fetchSizeBytes

socketTimeoutMs

public int socketTimeoutMs

fetchMaxWait

public int fetchMaxWait

bufferSizeBytes

public int bufferSizeBytes

scheme

public MultiScheme scheme

ignoreZkOffsets

public boolean ignoreZkOffsets

startOffsetTime

public long startOffsetTime

maxOffsetBehind

public long maxOffsetBehind

useStartOffsetTimeIfOffsetOutOfRange

public boolean useStartOffsetTimeIfOffsetOutOfRange

metricsTimeBucketSizeInSecs

public int metricsTimeBucketSizeInSecs

minFetchByte

public int minFetchByte

Constructor Detail

KafkaConfig

public KafkaConfig(BrokerHosts hosts,
                   String topic)

KafkaConfig

public KafkaConfig(BrokerHosts hosts,
                   String topic,
                   String clientId)