Package org.apache.storm.sql.kafka
-
Class Summary Class Description KafkaDataSourcesProvider Create a Kafka spout/sink based on the URI and properties.RecordTranslatorSchemeAdapter RecordTranslator that delegates to a Scheme.
| Class | Description |
|---|---|
| KafkaDataSourcesProvider |
Create a Kafka spout/sink based on the URI and properties.
|
| RecordTranslatorSchemeAdapter |
RecordTranslator that delegates to a Scheme.
|