メッセージングのキューにある収集データをスキーマレス加工などの入力データとして利用するには、メッセージングのキューイング機構(Apache Kafka)のライブラリを使用してデータを取得するアプリケーションを作成する必要があります。
Apache Kafkaのライブラリを使用したアプリケーション開発については、OSSのオンラインドキュメントを参照してください。