Java 类com.amazonaws.services.kinesis.clientlibrary.interfaces.v2.IRecordProcessor 实例源码

@Override
public IRecordProcessor createProcessor() {
  return new KinesisSpanProcessor(collector);
}

@Override
public IRecordProcessor createProcessor() {
    return new ZombieRecordProcessorOnMemory(lectures);
}

@Override
public IRecordProcessor createProcessor() {
  return new StreamSetsRecordProcessor(context, parserFactory, maxBatchSize, error);
}