141.6. HBase べき等リポジトリー

camel-hbase コンポーネントは、各メッセージが 1 回だけ処理されるようにする場合に使用できるべき等リポジトリーも提供します。HBase べき等リポジトリーは、テーブル、列ファミリー、および列修飾子で設定され、メッセージごとにそのテーブルに行を作成します。

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

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