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.