public class KafkaDataSourcesProvider extends Object implements DataSourcesProvider
Create a Kafka spout/sink based on the URI and properties. The URI has the format of kafka://zkhost:port/broker_path?topic=topic. The properties are in JSON format which specifies the producer config of the Kafka broker.
| Constructor and Description |
|---|
KafkaDataSourcesProvider() |
| Modifier and Type | Method and Description |
|---|---|
DataSource |
construct(URI uri,
String inputFormatClass,
String outputFormatClass,
List<FieldInfo> fields) |
ISqlTridentDataSource |
constructTrident(URI uri,
String inputFormatClass,
String outputFormatClass,
Properties properties,
List<FieldInfo> fields) |
String |
scheme() |
public String scheme()
scheme in interface DataSourcesProviderpublic DataSource construct(URI uri, String inputFormatClass, String outputFormatClass, List<FieldInfo> fields)
construct in interface DataSourcesProviderpublic ISqlTridentDataSource constructTrident(URI uri, String inputFormatClass, String outputFormatClass, Properties properties, List<FieldInfo> fields)
constructTrident in interface DataSourcesProviderCopyright © 2021 The Apache Software Foundation. All Rights Reserved.