jlengrand/quarkus-workshop
1
0
Fork 0
mirror of https://github.com/jlengrand/quarkus-workshop.git synced 2026-03-10 08:41:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

kafka

Browse Source
This commit is contained in:
jamesfalkner
2019-07-16 18:16:49 -04:00
parent b955998348
commit 31d1e19ec9
2 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

BIN
docs/images/kafkaarch.png Normal file
View File

Binary file not shown.
Side by Side

After

Width:  |  Height:  |  Size: 38 KiB

6
docs/kafka.adoc
View File

@@ -95,6 +95,12 @@ mvn quarkus:add-extension -Dextensions="kafka"
This will add the necessary entries in your `pom.xml` to bring in the Kafka extension. This will add the necessary entries in your `pom.xml` to bring in the Kafka extension.
== The Application You Will Build
The app consists of 3 components that pass messages via Kafka and an in-memory stream, then uses SSE to push messages to the browser. It looks like:
image::kafkaarch.png[kafka, 800]
== Create name generator == Create name generator
To start building the app, create a new Java class in the `org.acme.people.stream` called `NameGenerator`. This class will generate random names and publish them to our Kafka topic for further processing. Use this code: To start building the app, create a new Java class in the `org.acme.people.stream` called `NameGenerator`. This class will generate random names and publish them to our Kafka topic for further processing. Use this code: