Come usare Apache kafka con Spring mvc? È possibile?

Question

Sono un principiante con apache kafka e cerco di imparare confluenza - kafka - riposo - utils, tuttavia mi confondo con come posso usarlo.

Durante la ricerca ho trovato questa documentazione https://spring.io/blog/2015/04/15/using-apache-kafka-for-integration-and-data-processing-pipelines-with-spring

E 'molto buona documentazione, ma non mi aiuta ad imparare di riposo-utils.

Il codice git di confluenti Kafka riposo utils è

https://github.com/confluentinc/kafka-rest è dimostrare come utilizzare riposo Kafka. Ma voglio sapere la procedura esatta per essere più consapevole al riguardo. con qualche semplice spiegazione. Qualcuno mi può suggerire alcuni collegamenti con come uso il client di riposo. Per favore guidami verso questo.

Potrebbe essere una domanda stupida ma non ho altra opzione da apprendere.

grazie in anticipo.

Answer 1

Prima prova a create a REST service using spring MVC tenendo da parte le cose di kafka.

Una volta eseguito un tipo di servizio REST 'hello world', quindi selezionare Kafka Docs.

Consultare i documenti su come creare un cluster kafka ed eseguire programmi di console e produttori predefiniti per controllare il cluster.

Ora, scrivere un programma java principale e creare un produttore kafka utilizzando Kafka Clients API. Fai riferimento ai suoi documenti. Assicurati che i messaggi inviati attraverso il programma principale raggiungano il consumatore.

Ora, immettere il contenuto di questo programma principale nel servizio di riposo, in modo che i messaggi passati nel corpo della richiesta vengano ora passati al cluster kafka e siano leggibili dal consumatore.

Spero che aiuti.