Benötigen Beispielcode für Spring Integration Beispiel für AWS S3 als inBound und Apache Kafka als Outbound

Question

Benötigen Sie Beispiel für Spring Integration für AWS S3 als eingehende und Apache Kafka als ausgehende.

Ich möchte Daten von aws s3 lesen und sie analysieren müssen und produzieren es zu Apache kafka Thema

Answer 1

Hier ist ein Code-Schnipsel. Es funktioniert nicht, aber zumindest etwas, von dem man ausgehen kann. Niemand hier wird Code für Sie schreiben:

<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>