Écrivent de manière asynchrone au nuage de kafka de nuage de ressort

Question

Je veux écrire de manière asynchrone au nuage de kafka de nuage de ressort. Par exemple

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 
    } 

} 

Donc dans l'exemple ci-dessus. Je veux savoir comment appeler la méthode writeToStream, de sorte qu'il va écrire à kafka. Fondamentalement, je veux écrire à diffuser à la fin de la tâche contrairement à l'interrogation. S'il vous plaît aider.

Answer 1

@Autowired 
private MessageChannel output; 

... 

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

Cependant, la raison pour laquelle vous en avez besoin n'est pas claire; les kafka envoie sont déjà asynchrones par défaut.