Springのサンプルコードが必要です。aws S3がinBoundで、Apache kafkaがアウトバウンドである必要があります。

Question

aws s3のインバウンドとしてのSpring Integrationと、アウトバウンドとしてのApache kafkaの例が必要です。

私はAWS S3からデータを読みたいとここでそれらを解析し、Apacheのカフカ話題に

Answer 1

を、それを生成する必要があるが、いくつかのコードスニペットです。それは動作しませんが、少なくとも何かから始める。ここに誰もコードを書くつもりはありません。

<bean id="s3SessionFactory" 
      class="org.springframework.integration.aws.support.S3SessionFactory"/> 

<int-aws:s3-inbound-channel-adapter channel="s3Channel" 
        session-factory="s3SessionFactory" 
        filename-pattern="*.txt" 
        local-directory="." 
        remote-directory-expression="'my_bucket'"> 
    <int:poller fixed-rate="1000"/> 
</int-aws:s3-inbound-channel-adapter> 


<int:transformer input-channel="s3Channel" output-channel="kafkaChannel" 
     ref="myTransformer"/> 

<int-kafka:outbound-channel-adapter 
           kafka-template="template" 
           channel="kafkaChannel" 
           topic="foo" 
           message-key-expression="'bar'" 
           partition-id-expression="2"> 
</int-kafka:outbound-channel-adapter> 

<bean id="template" class="org.springframework.kafka.core.KafkaTemplate"> 
    <constructor-arg> 
     <bean class="org.springframework.kafka.core.DefaultKafkaProducerFactory"> 
      <constructor-arg> 
       <map> 
        <entry key="bootstrap.servers" value="localhost:9092" /> 
       </map> 
      </constructor-arg> 
     </bean> 
    </constructor-arg> 
</bean>