Package org.apache.storm.kafka.spout.trident

package org.apache.storm.kafka.spout.trident

Related Packages

Package	Description
org.apache.storm.kafka.spout
org.apache.storm.kafka.spout.trident.internal
org.apache.storm.kafka.spout.internal
org.apache.storm.kafka.spout.metrics2
org.apache.storm.kafka.spout.subscription

Classes

Class	Description
KafkaTridentOpaqueSpoutEmitter<K,V>
KafkaTridentSpoutBatchMetadata	Wraps transaction batch information.
KafkaTridentSpoutConfig<K,V>	Defines the required Kafka-related configuration for the Trident spouts.
KafkaTridentSpoutConfig.Builder<K,V>
KafkaTridentSpoutCoordinator<K,V>
KafkaTridentSpoutEmitter<K,V>
KafkaTridentSpoutOpaque<K,V>
KafkaTridentSpoutTopicPartition	ISpoutPartition that wraps TopicPartition information.
KafkaTridentSpoutTransactional<K,V>
KafkaTridentTransactionalSpoutEmitter<K,V>
TopicPartitionSerializer