NIFIを使用してKafkaからCassandraに挿入

Question

私はカフカのトピックからCassandraに巨大なCSVファイルを読み込む必要があります。私は同じを達成するためにApache Nifiを設定しました。

フロー：

ユーザーはNifiの設定上のコントロールを持っていません。 CSVが配置されているURLのみを指定します。 WebアプリケーションはURLをカフカのトピックに書き込みます。 Nifiはファイルを取り出してCassandraに挿入します。

NifiがCSVファイルのすべての行をCassandraに挿入したことをどのように知ることができますか？私は挿入が完了したことをユーザーに知らせる必要があります。

ご協力いただければ幸いです。

Answer 1

解決策が見つかりました。

MergeContentプロセッサを使用すると、" fragment.identifier "と同じ値を持つすべてのFlowFilesがグループ化されます。 MergeContentがそれらの断片化を解消すると、ユーザーに通知することができます。