org.apache.storm.kafka.trident

Class TridentKafkaConfig

java.lang.Object

org.apache.storm.kafka.KafkaConfig

org.apache.storm.kafka.trident.TridentKafkaConfig

All Implemented Interfaces:

Serializable

public class TridentKafkaConfig
extends KafkaConfig

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
IBatchCoordinator	coordinator

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
TridentKafkaConfig(BrokerHosts hosts, String topic)
TridentKafkaConfig(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

coordinator

public final IBatchCoordinator coordinator

Constructor Detail

TridentKafkaConfig

public TridentKafkaConfig(BrokerHosts hosts,
                          String topic)

TridentKafkaConfig

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