春の雲カフカストリームに非同期で書き込み

Question

春の雲カフカストリームに非同期で書きたいと思います。例えば、

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 
    } 

} 

したがって、上記の例では、 writeToStreamメソッドを呼び出す方法を知りたいので、kafkaに書き戻します。基本的には、ポーリングとは異なり、タスクの完了時にストリームに書きたいと思っています。助けてください。

Answer 1

ただし、これがなぜ必要なのかはっきりしません。 kafkaセンドはデフォルトでは既に非同期です。