Overview

Produce messages to and consume messages from a Kafka cluster using the Java Producer and Consumer, and Kafka Streams API.

Documentation

You can find the documentation and instructions for running this Java example at https://docs.confluent.io/platform/current/tutorials/examples/clients/docs/java.html

Run in Gitpod

1. Create a Confuent Cloud account at https://confluent.cloud, create a cluster, and then create a schema registry.
2. Create a API keys for your cluster and schema registry.
3. Finally, make sure these environment variables are set at https://gitpod.io/variables and scoped to this repository

• CONFLUENT_CLOUD_EMAIL (for the confluent CLI)
• CONFLUENT_CLOUD_PASSWORD (for the confluent CLI)
• CCLOUD_ENV_ID (to choose a specific environment for the confluent CLI)
• CCLOUD_API_KEY
• CCLOUD_API_SECRET
• CCLOUD_BOOTSTRAP_SERVER (includes kafka port)
• CCLOUD_SR_URL
• CCLOUD_SR_API_KEY
• CCLOUD_SR_API_SECRET

Now you can run your clients in YOUR OWN Confluent Cloud cluster with Gitpod! Enjoy!

Video Demonstration