143.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);