Develop consumers and producers in Java

Learning path | 5 resources | 1 hr | Published on March 30, 2022
Continue your Apache Kafka journey by developing consumers and producers in Java to stream data using Red Hat OpenShift Streams for Apache Kafka.

  1. Overview: Develop consumers and producers in Java
  2. Create a topic Page | 15 mins
  3. Clone the Git repository Page | 15 mins
  4. Start the producer and consumer Java applications Page | 15 mins
  5. Produce and consume songs Page | 15 mins

Page

Clone the Git repository

Java Kafka OpenShift
RHOSAK path 3 - resource 2

Clone the repository containing the Java code for the producer and consumer applications into your development environment:

git clone git@github.com:redhat-cloud-services-tmm/kafka-tutorial.git kafka-tutorial

Under the apps directory, this repository contains two Java applications: one that acts as a Kafka producer (song-app) and another that acts as a Kafka consumer (song-indexer-app). These applications use MicroProfile Reactive Messaging to abstract away the specifics of the Kafka client library using Channels and Emitters.

Explore the code and you will see the Kafka and channel configurations in the application.properties. The Java API for RESTful Web Services (JAX-RS) is used to expose REST APIs that allow HTTP clients to send requests that produce messages to Kafka and that stream consumed events back to the HTTP client. 

Previous resource
Create a topic
Next resource
Start the producer and consumer Java applications