142.7. HBase Idempotent 软件仓库

camel-hbase 组件还提供幂等存储库,当您想要确保仅处理每条消息时,可以使用它。HBase idempotent 存储库配置了表格、列系列和列限定符,并将创建到每个消息的行。

HBaseConfiguration configuration = HBaseConfiguration.create();
HBaseIdempotentRepository repository = new HBaseIdempotentRepository(configuration, tableName, family, qualifier);

from("direct:in")
  .idempotentConsumer(header("messageId"), repository)
  .to("log:out);