Package | Description |
---|---|
org.apache.storm.kafka.spout.trident | |
org.apache.storm.kafka.spout.trident.internal | |
org.apache.storm.kafka.trident |
Class and Description |
---|
KafkaTridentSpoutBatchMetadata
Wraps transaction batch information.
|
KafkaTridentSpoutConfig
Defines the required Kafka-related configuration for the Trident spouts.
|
KafkaTridentSpoutConfig.Builder |
KafkaTridentSpoutEmitter |
KafkaTridentSpoutTopicPartition
ISpoutPartition that wraps TopicPartition information. |
Class and Description |
---|
KafkaTridentSpoutConfig
Defines the required Kafka-related configuration for the Trident spouts.
|
Class and Description |
---|
KafkaTridentSpoutConfig
Defines the required Kafka-related configuration for the Trident spouts.
|
Copyright © 2020 The Apache Software Foundation. All rights reserved.