我在Camel中使用AWS-KINESIS终端节点来读取AWS Kinesis内容流。我可以很好地阅读消息，但是如何在信息流中检查消息呢？在标准的AWS Kinesis Java客户端库中，您具有工作程序和处理器的概念，但这似乎在Camel中被完全绕开了。
我的路线：
from("aws-kinesis://" + CONTENT_STREAM_NAME + "?amazonKinesisClient=#kinesisClient").
routeId(KINESIS_EVENT_READ).
bean(recordHandler);
在记录处理程序中，我想在正确处理记录时检查记录。
RecordHandler的@Handler
@Handler
public void handleRecord(@Body Record record) {
processEvent(record); // I would like to checkpoint after this...
}
有指针吗？
适用于骆驼的AWS-KINESIS当前使用AWS开发工具包的同步Kinesis部分。您要引用的Workers，Processor和Checkpoint来自KCL（Kinesis Client Libary），这是访问Kinesis（包括每个分区的线程和检查点）的更高级的方法。似乎还没有基于KCL的Camel消费者组件，也没有相应的基于KPL的生产者组件。
本文收集自互联网，转载请注明来源。
如有侵权，请联系 [email protected] 删除。
我来说两句