Exercise 2 - Reactive Messaging with MicroProfile
Last updated
Last updated
In this lab you'll learn how to use reactive messaging with MicroProfile Messaging. With simple Java annotations messages can be sent and received in memory as well as via Apache Kafka.
MicroProfile Messaging implements the Reactive Streams standard which defines how to do asynchronous stream processing for different programming languages independently from specific libraries.
The interfaces of the main Reactive Streams components Subscriber, Publisher and Processor have been available since JDK 9. The implementation of these interfaces is provided by MicroProfile.
The 'Articles' service writes messages to Kafka after new articles have been created. In this lab we'll take a look how these messages can be read from the 'Web-API' service.
Let's take a look at a Java class which receives incomping messages from Kafka and sends outgoing in-memory messages.
Invoke the following command in the Cloud Shell.
The @Incoming annotation indicates that the method consumes the items from the topic 'new-article-created'. The @Outgoing annotation indicates that the objects returned by the method are sent to the stream 'stream-new-article'. @Broadcast indicates that the item are dispatched to all subscribers.
The snippet is a Subscriber as well as a Publisher which means that it is automatically also a Processor which can, for example, convert incoming messages and forward them.
Let's make a simple change and redeploy the microservice by adding this line.
Exit the Editor via 'Ctrl-X', 'y' and 'Enter'.
Confirm that the changes have been saved.
The incoming messages in the snippet above are received from Kafka. The 'Articles' service writes these messages to Kafka after new articles have been created.
In order to subscribe to these Kafka messages in Quarkus, the topic needs to be configured in application.properties.
On the 'Builds' page wait until the new build has been completed.
Once completed, delete the 'Web-API' pod which causes a new pod with the latest image to be started.
Create a new article by invoking a curl post command. You can get the URL from the script show-urls.
In order to see the logs, you can do two things:
Use the following instructions which leverage a terminal
Use distributed logging as documented in Lab 5
In the terminal get the pod name:
After this invoke this command to display the logs of the pod.
Your added line shows up in the logs now.
