类的使用
org.apache.pulsar.io.kinesis.KinesisSourceConfig

使用KinesisSourceConfig的程序包

程序包	说明
org.apache.pulsar.io.kinesis

org.apache.pulsar.io.kinesis中KinesisSourceConfig的使用

返回KinesisSourceConfig的org.apache.pulsar.io.kinesis中的方法

限定符和类型	方法和说明
static KinesisSourceConfig	KinesisSourceConfig.load(Map<String,Object> map)
static KinesisSourceConfig	KinesisSourceConfig.load(String yamlFile)

参数类型为KinesisSourceConfig的org.apache.pulsar.io.kinesis中的构造器

构造器和说明
KinesisRecordProcessor(LinkedBlockingQueue<KinesisRecord> queue, KinesisSourceConfig config)
KinesisRecordProcessorFactory(LinkedBlockingQueue<KinesisRecord> queue, KinesisSourceConfig kinesisSourceConfig)