storm.kafka
Class KafkaConfig

java.lang.Object
  extended by 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
 int bufferSizeBytes
           
 String clientId
           
 int fetchMaxWait
           
 int fetchSizeBytes
           
 boolean forceFromStart
           
 BrokerHosts hosts
           
 long maxOffsetBehind
           
 int metricsTimeBucketSizeInSecs
           
 MultiScheme scheme
           
 int socketTimeoutMs
           
 long startOffsetTime
           
 String topic
           
 boolean useStartOffsetTimeIfOffsetOutOfRange
           
 
Constructor Summary
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

forceFromStart

public boolean forceFromStart

startOffsetTime

public long startOffsetTime

maxOffsetBehind

public long maxOffsetBehind

useStartOffsetTimeIfOffsetOutOfRange

public boolean useStartOffsetTimeIfOffsetOutOfRange

metricsTimeBucketSizeInSecs

public int metricsTimeBucketSizeInSecs
Constructor Detail

KafkaConfig

public KafkaConfig(BrokerHosts hosts,
                   String topic)

KafkaConfig

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


Copyright © 2015 The Apache Software Foundation. All Rights Reserved.