spring-integration - Sprint Integration DSL - HTTP インバウンド アダプターおよびポーラー

Question

私はSpring Integrationにかなり慣れていないので、簡単なユースケースをセットアップしようとしています:

リモート REST エンドポイントをポーリングし、返されたペイロードを複数の行に分割して、Kafka アウトバウンド アダプターに送信します。私は、ファイル アダプタを使用する同様のことを成功させましたが、HTTP アダプタに行き詰まっています。ポーラーを HTTP 受信アダプターに関連付ける方法がわかりません。

これまでのところ、私のアプローチは単純なフローを作成することでした。

return IntegrationFlows
  .from
    (
      Http.inboundChannelAdapter("http://localhost:8080/data")
        .requestMapping(m -> m.methods(HttpMethod.GET))
        .replyTimeout(20)
      )
  .channel(INBOUND_DEMO_CHANNEL)
  .get();

はinboundChannelAdapterを受け入れないようですPoller。ファイルを使用した前回の試みFileReadingMessageSourceで、フローが次のようになるように を作成しました。

return IntegrationFlows.from(fileReadingMessageSource,
    // POLLER CONFIGURATION
    .poller(Pollers.fixedDelay(period)
    ...
    .get();

しかし、HTTP メッセージ ソースに相当するものが見つかりません。