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)
}

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）