Spring Boot 4 Microservices & REST APIs · レッスン

Kafkaプロデューサー入門

Spring Kafkaプロデューサーを使って、Kafkaトピックにメッセージを発行する方法を学びます。

「Kafkaプロデューサー入門」はCoddyKit上の無料Spring Boot 4 Microservices & REST APIsレッスンです。これはレッスン1/3です。下記で完全なレッスンを無料で読むことができます。その後、ブラウザ内の組み込みコードエディタと24時間対応のAIチューターでハンズオン演習できます。これはSpring Boot 4 Microservices & REST APIs学習パスの一部であり、ウェブとCoddyKitアプリ全体で進捗が同期されます。 Spring Boot 4 Microservices & REST APIsコースには全3レッスンが含まれています。

このレッスンの一部はまだ翻訳されておらず、英語で表示されています。

Welcome to Event-Driven!

In modern applications, systems often need to react to events as they happen, rather than just waiting for requests. This is the core idea behind Event-Driven Architecture (EDA).

EDA helps build flexible and scalable systems by allowing different parts of your application to communicate asynchronously through events.

What is Apache Kafka?

Apache Kafka is a powerful, distributed streaming platform often used to build event-driven microservices. It's designed for high-throughput, low-latency processing of real-time data feeds.

Think of it as a super-fast, durable message queue that can handle huge amounts of data.

Kafka's Core Concepts

Kafka revolves around a few key ideas:

Producers: Applications that send data (messages/records) to Kafka.
Consumers: Applications that read data from Kafka.
Topics: Categories or feeds to which records are published. Consumers subscribe to topics.
Brokers: Kafka servers that store the published data.

The Producer's Job

A Kafka Producer is responsible for creating and sending data records to Kafka topics. These records are often key-value pairs, though the key is optional.

Producers don't wait for acknowledgements from consumers; they just publish messages to the topic and move on, making the communication asynchronous.

Adding Spring Kafka

To integrate Kafka into your Spring Boot application, you'll need the spring-kafka dependency. This module provides convenient abstractions for interacting with Kafka.

Add this to your pom.xml:

<dependency>
  <groupId>org.springframework.kafka</groupId>
  <artifactId>spring-kafka</artifactId>
</dependency>

Producer Configuration

Spring Kafka producers need configuration, typically in application.properties. The most important settings are the Kafka broker addresses and the serializers for your message keys and values.

Serializers convert your Java objects into bytes for transmission over the network.

Config Example

Here's a basic configuration for a Kafka producer:

spring.kafka.producer.bootstrap-servers=localhost:9092
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer

bootstrap-servers points to your Kafka broker. We're using StringSerializer for both key and value.

Introducing KafkaTemplate

KafkaTemplate is the central class in Spring Kafka for sending messages. It simplifies the process of interacting with Kafka brokers.

You can inject it into your Spring components and use its send() methods to publish messages to specified topics.

Sending a Simple Message

Let's see how to send a basic 'Hello Kafka!' message to a topic named 'my-topic' using KafkaTemplate.

Run this example (ensure a Kafka broker is running on localhost:9092 and 'my-topic' exists).

import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
import org.springframework.kafka.core.KafkaTemplate;

@SpringBootApplication
public class KafkaProducerApp {

  public static void main(String[] args) {
    SpringApplication.run(KafkaProducerApp.class, args);
  }

  @Bean
  public CommandLineRunner commandLineRunner(KafkaTemplate<String, String> kafkaTemplate) {
    return args -> {
      String topic = "my-topic";
      String message = "Hello Kafka!";
      System.out.println("Sending message: " + message + " to topic: " + topic);
      kafkaTemplate.send(topic, message);
      System.out.println("Message sent. Check your Kafka consumer.");
    };
  }
}

Messages with Keys

Messages can also be sent with a key. Kafka uses keys to ensure messages with the same key go to the same partition within a topic, maintaining order for related data.

This is crucial for scenarios where message order matters, like user events or stock updates for a specific product.

Producer Quick Check

Which of the following are essential components or concepts when setting up a Spring Kafka producer?

Lesson Summary

You've taken your first steps into event-driven architecture with Kafka! We learned that Kafka is a distributed streaming platform, and producers are applications that send messages to topics.

We also covered setting up Spring Kafka, configuring producer properties, and using KafkaTemplate to send messages, including those with keys. This forms the foundation for building event-publishing microservices!

よくある質問

「Kafkaプロデューサー入門」レッスンは無料ですか？

はい。「Kafkaプロデューサー入門」の完全なテキストはこのウェブで無料で読めます。インタラクティブに演習し（組み込みコードエディタと24時間対応のAIチューター）、Spring Boot 4 Microservices & REST APIsコースの残りをアンロックするには、CoddyKit PROにアップグレードしてください。 Spring Boot 4 Microservices & REST APIsコースには全3レッスンが含まれています。

「Kafkaプロデューサー入門」で何を学びますか？

Spring Kafkaプロデューサーを使って、Kafkaトピックにメッセージを発行する方法を学びます。ブラウザで直接実行するハンズオンコードでSpring Boot 4 Microservices & REST APIsを演習し、24時間対応のAIチューターがレッスンを進める中での質問に答えます。

Spring Boot 4 Microservices & REST APIsを始めるのに経験は必要ですか？

事前経験は必要ありません。CoddyKitのSpring Boot 4 Microservices & REST APIsは初級者から上級者向けに構成されているため、ここから始めるか最初から始めて、自分のペースで進むことができます。これはレッスン1/3です。

「Kafkaプロデューサー入門」レッスンにはどのくらい時間がかかりますか？

ほとんどのCoddyKitレッスンは約5～10分かかります。各レッスンはコンパクトでインタラクティブなので、着実に進歩し、ウェブとアプリ全体で正確に前回の場所から再開できます。

このSpring Boot 4 Microservices & REST APIsレッスンでコードを書いて実行できますか？

はい。すべてのSpring Boot 4 Microservices & REST APIsレッスンに組み込みコードエディタが含まれているため、ブラウザでリアルコードを書いて実行し、即座のAIフィードバックを取得できます。ローカル設定は不要です。

このコースのすべてのレッスン

← Spring Boot 4 Microservices & REST APIsに戻る