标题可能有点混乱。我会尽力使它更清楚。
假设我有一个AWS Lambda函数,它具有两个不同的Kinesis流A和B作为输入事件源。
那么,对于以下情况,由于KinesisEvent实例包含一批记录,该批处理将包含来自单个流的记录,还是本质上它包含来自流A和B的记录?
public class ProcessKinesisEvents {
public void recordHandler(KinesisEvent event, Context context) {
...
}
}
Run Code Online (Sandbox Code Playgroud)