Spring의 예제 코드가 필요함 aws S3 inBound와 Apache kafka가 아웃 바운드 인 경우

Question

aws s3을 아웃 바운드로, Apache kafka를 아웃 바운드로 Spring 통합에 대한 예제가 필요하다.

나는 AWS의 S3에서 데이터를 읽고이를 분석하고 아파치 카프카 주제 여기

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>