Kinesis 生产者库KPL并获取计数成功发送记录异步

如何解决Kinesis 生产者库KPL并获取计数成功发送记录异步

我遇到了 KPL 问题。我在 KPL 的帮助下将记录发送到 kinesis 数据流。我想记录每次发送的记录数。我该怎么做？

val callback = new FutureCallback<UserRecordResult> {

            @Override
            public void onFailure(Throwable t) {//some code}

            @Override
            public void onSuccess(UserRecordResult result) { //some }
}

    val executor = Executors.newCachedThreadPool() 
    listRecords.forEach { 
    
   val userRecord = UserRecord(
       streamName,somePartitionKey,ByteBuffer.wrap(objectMapper.writeValueAsBytes(it))
    )

    val result = kinesisProducer.addUserRecord(userRecord)
    
    Futures.addCallback(result,callback,executor)
}