使用Apache端点，我如何在Kinesis流中对消息进行检查点？

Question

我在Camel中使用AWS-KINESIS端点来读取AWS动态内容流.我可以很好地读取消息，但是如何在流上检查消息呢？在标准的AWS Kinesis客户端库中，您有工人和处理器的概念，但这似乎完全被Camel忽略了。

我的路线：

  from("aws-kinesis://" + CONTENT_STREAM_NAME + "?amazonKinesisClient=#kinesisClient").
        routeId(KINESIS_EVENT_READ).
        bean(recordHandler);

在记录处理程序中，我希望在正确处理记录时检查记录。

记录器的@Handler

    @Handler
    public void handleRecord(@Body Record record) {
        processEvent(record); // I would like to checkpoint after this...
    }

有什么指示吗？

Answer 1

AWS- Camel目前使用的是同步AWS SDK的动态部分.您所引用的Worker、处理器和检查点来自KCL (动态客户Libary)，这是一种更高级的访问Kinesis的方法(包括每个分区一个线程，以及检查点)。目前还没有基于KCL的Camel消费组件，也没有相应的基于KPL的生产商组件。