Package org.apache.storm.kafka.spout.trident
-
Class Summary 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 wrapsTopicPartition
information.KafkaTridentSpoutTransactional<K,V> KafkaTridentTransactionalSpoutEmitter<K,V> TopicPartitionSerializer