Hands On: Introduction to Spring Boot for Apache Kafka

Hi, this is Victor Gamov from Confluent. And in this lesson, I will show you how you can set up and use Spring Boot project for KAFKA and use it with Confluent Cloud. Let's get to it. We gonna start at one place where you can start all your new Spring Boot projects. It's the "start.spring.io". For this, we're going to be using Gradle Project and we will stick to Java today. We're gonna use stable version of Spring Boot and by the time of recording, it was 2.4.5. Let's put some of the Group ID and Artifact ID and Name of the project here. So, I'm gonna be using "io.confluent.developer" naturally. Let's call it "spring-ccloud", keep the name like this, with say "Demo Project for Spring Boot with Confluent Cloud" and we need to fix this package here. I'm going to be using Java packaging "Jar". Gonna be using Java 11. In this case, I also need to add a few more dependencies. We're going to be starting with a Spring Boot for Apache Kafka for Kafka streams. We're also going to be using Spring Cloud Stream later in this lesson so we will use this as a dependency here as well. We add Lombok because we're gonna be using Java but I also want to remove some of the boilerplate code. We use Lombok and the one last but not least, a Reactive Web for Spring Boot. In some of the lessons, I will show you how we can expose certain services through the rest, and this is what we're gonna be using. So, once we're ready, I click "Generate" and download zip archive on my computer and I'm going to my terminal and I need to unzip it. I'm going to my "Downloads" folders and I'll click "unzip spring-ccloud". And I opened my IDE in this folder. While this project is opening in my IDE, let's switch to Confluent Cloud. You can open your browser and then navigate to your Confluent Cloud account. This is important to know that to use this, you need to have your account created. You can pause this video right now, go to Confluent Cloud, sign up this. You can find the promo code in the description below in this video. And after that, you can return to this video and continue to this lesson, all right? Do it right now. So you have already created your new account in Confluent Cloud. You might see some default environment and it's okay to stick to default environment. I like to have environments for different use cases in this particular case for my Spring Kafka, I already have spring Kafka environment. So in this environment, I will create a new cluster that we're going to be using in this lesson and some other lessons that we're going to be teaching in this course. So I'll click "Get started with the cluster". I'm gonna be using "Standard" cluster. I go to start "begin the configuration". I will stick with the Google Clouds. U.S. East is closer to me. I'm on the east coast in the United States. "us-east4", I will be using single zone. Click continue. I will call it "spring_kafka_0". Maybe I will be using something, some new clusters, so it's always good to put index here. And when I click "Launch cluster", I should be able to use this cluster in my application. Now, to connect my Spring Boot application, I need to do a few more things here. If I go to "Clients", and I'll find this button here called "Spring Boot". When I click it, it will be populated with some of the template that you will use to configure your Spring Boot application. In this particular case, you can see there's two things: "Cluster_API_KEY" and "Cluster_API_SECRET" are missing here so we want to replace it with the real values. So I'm going and I click here and I can say "spring kafka lesson" and I click continue and now my key and API password were populated here. So what I do here, I'm just go ahead and copy this things here and go into my project. In my project I will find this "application.properties" and this is where I need to put my configuration for this project. There will be a bootstrap server, some of the security credentials, and this is how you configure your project to use with Confluent Cloud. In the next lesson, I will show you how we can use this project that we just configured and connected to Confluent Cloud to send messages and receive messages from Confluent Cloud.