我有一个用 KCL 用 Java 编写的 Kinesis 消费者。从消费者方面,我可以使用 setMaxRecords 方法限制速率,以设置一批中记录的最大限制。
我的问题是:如果我不设置任何限制,那么确定一批中有多少条记录的逻辑是什么?允许的最大值是否有默认值?
我有一个用 KCL 用 Java 编写的 Kinesis 消费者。从消费者方面,我可以使用 setMaxRecords 方法限制速率,以设置一批中记录的最大限制。
我的问题是:如果我不设置任何限制,那么确定一批中有多少条记录的逻辑是什么?允许的最大值是否有默认值?
使用 KCL 时,批处理中的默认最大记录数为 10000。
有关更多详细信息,请参阅KinesisClientLibConfiguration 源代码。