Asynchron zu Frühlingswolke Kafka Stream schreiben

Question

Ich möchte asynchron in Spring Cloud Kafka Stream schreiben. Zum Beispiel

Class SomeClass{ 

@StreamLister(Processor.INPUT) 
public void receiveEvents(String e){ 

    class ThreadExecutor implements Runnable { 
    private String message; 

    public ThreadExecutor(message){ 
     this.message = message; 
    } 

    public void run(){ 
     //after processing the string I will publish it 
     message = message + "done"; 
     writeToStream(message); 
    } 
    } 

    Executors.newCachedThreadPool().execute(new ThreadExecutor(e)); 
} 

@SendTo //not sure how to write it back 
public Message<String> writeToStream(String message){ 
    //this is what I want to know 
    } 

} 

Also im obigen Beispiel. Ich möchte wissen, wie man die writeToStream-Methode aufruft, so dass sie zurück in kafka schreibt. Im Grunde möchte ich schreiben, um bei der Erfüllung der Aufgabe zu streamen, im Gegensatz zum Polling. Bitte helfen Sie.

Answer 1

@Autowired 
private MessageChannel output; 

... 

    output.send(MessageBuilder.withPayload(data).build()); 

Es ist jedoch nicht klar, warum Sie das brauchen; Die Kafka-Sends sind standardmäßig bereits asynchron.