0Pricing
Advanced Spring Boot 4: Event-Driven Architecture (Kafka) · บทเรียน

การส่งข้อความด้วย KafkaTemplate

ใช้ KafkaTemplate ของ Spring เพื่อส่งข้อความไปยังท็อปปิก Kafka ด้วยโค้ด รวมถึงแนวทางแบบทำงานพร้อมกันและไม่พร้อมกัน

การส่งข้อความด้วย KafkaTemplate เป็นบทเรียน Advanced Spring Boot 4: Event-Driven Architecture (Kafka) ฟรีบน CoddyKit นี่คือบทเรียนที่ 2 จากทั้งหมด 4 บทเรียน คุณสามารถอ่านบทเรียนทั้งหมดด้านล่างฟรี — จากนั้นลองปฏิบัติด้วยตัวคุณเองในเบราว์เซอร์พร้อมตัวแก้ไขโค้ดในตัวและติวเตอร์ AI ตลอด 24/7 บทเรียนนี้เป็นส่วนหนึ่งของเส้นทางการเรียน Advanced Spring Boot 4: Event-Driven Architecture (Kafka) และความก้าวหน้าของคุณจะซิงค์ข้ามเว็บและแอป CoddyKit คอร์ส Advanced Spring Boot 4: Event-Driven Architecture (Kafka) มีบทเรียนทั้งหมด 4 บทเรียน

บางส่วนของบทเรียนนี้ยังไม่ได้รับการแปล และแสดงเป็นภาษาอังกฤษ

Meet Spring's KafkaTemplate

Welcome to sending messages with Spring Boot and Kafka! At the heart of sending messages is Spring's KafkaTemplate.

  • It simplifies interacting with Kafka.
  • It handles connection management and serialization.
  • It lets you send messages to any Kafka topic easily.

Think of it as your primary tool for producing events.

Injecting KafkaTemplate in Spring

To use KafkaTemplate, you simply inject it into your Spring component (like a service or controller). Spring Boot auto-configures it for you, provided you have the spring-kafka dependency.

You just need to declare it, and Spring handles the rest!

import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Service;

@Service
public class MyProducerService {
  private final KafkaTemplate<String, String> kafkaTemplate;

  public MyProducerService(KafkaTemplate<String, String> kafkaTemplate) {
    this.kafkaTemplate = kafkaTemplate;
  }
}

Sending Your First Message

The simplest way to send a message is using the send() method. You specify the topic name and the message payload.

A topic is a category or feed name where records are stored and published. The payload is the actual data you want to send.

Basic KafkaTemplate Send Example

Here's a complete, runnable Spring Boot application that sends a simple string message to a topic named my-topic. Make sure a Kafka broker is running (e.g., on localhost:9092) for this to work.

import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Component;

@SpringBootApplication
public class KafkaProducerApp {

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

  @Component
  public class MyMessageSender implements CommandLineRunner {
    private final KafkaTemplate<String, String> kafkaTemplate;

    public MyMessageSender(KafkaTemplate<String, String> kafkaTemplate) {
      this.kafkaTemplate = kafkaTemplate;
    }

    @Override
    public void run(String... args) throws Exception {
      String topic = "my-topic";
      String message = "Hello from CoddyKit!";
      kafkaTemplate.send(topic, message);
      System.out.println("Sent message: " + message + " to topic: " + topic);
    }
  }
}

Synchronous Message Sending

By default, kafkaTemplate.send() is asynchronous. However, you can make it synchronous by calling .get() on the returned ListenableFuture.

  • This blocks the current thread until the message is sent and acknowledged by Kafka.
  • Useful when you need immediate confirmation that a message was processed.
  • Can impact performance due to blocking, so use wisely.
import org.springframework.kafka.support.SendResult;
import java.util.concurrent.ExecutionException;

// ... in a service method
try {
  SendResult<String, String> result = 
    kafkaTemplate.send("sync-topic", "Sync message").get();
  System.out.println("Message sent synchronously: " + 
    result.getProducerRecord().value());
} catch (InterruptedException | ExecutionException e) {
  System.err.println("Failed to send message: " + e.getMessage());
}

Asynchronous Sending: The Preferred Way

For most applications, asynchronous sending is preferred. It allows your application to continue processing without waiting for Kafka's acknowledgment, improving throughput.

  • send() returns a ListenableFuture (or CompletableFuture in newer Spring versions).
  • You attach callbacks to this future to handle success or failure.
  • This non-blocking approach is key for scalable microservices.

Handling Asynchronous Success

To process the result of an asynchronous send, you use callbacks. The success callback receives a SendResult object, which contains details about the sent record.

This is where you'd log successful sends or update application state.

kafkaTemplate.send("async-topic", "Async message")
  .addCallback(
    result -> System.out.println("Sent successfully: " + 
      result.getProducerRecord().value()),
    ex -> System.err.println("Failed to send: " + 
      ex.getMessage())
  );

Handling Asynchronous Failure

The failure callback is crucial for robust applications. It's invoked if the message cannot be sent after retries, or if an immediate error occurs.

In this callback, you should:

  • Log the error details.
  • Implement retry logic (if not handled by Kafka config).
  • Move the message to a Dead Letter Topic (DLT) for later inspection.

Async Send with Callbacks Example

Let's update our previous example to use asynchronous sending with success and failure callbacks. This demonstrates a more robust way to send messages.

import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Component;

@SpringBootApplication
public class KafkaAsyncProducerApp {

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

  @Component
  public class MyAsyncMessageSender implements CommandLineRunner {
    private final KafkaTemplate<String, String> kafkaTemplate;

    public MyAsyncMessageSender(KafkaTemplate<String, String> kafkaTemplate) {
      this.kafkaTemplate = kafkaTemplate;
    }

    @Override
    public void run(String... args) throws Exception {
      String topic = "my-async-topic";
      String message = "Hello async from CoddyKit!";

      kafkaTemplate.send(topic, message)
        .addCallback(
          result -> System.out.println("Async success: " + result.getProducerRecord().value()),
          ex -> System.err.println("Async failure: " + ex.getMessage())
        );
      System.out.println("Attempted to send async message.");
    }
  }
}

Sending with Keys for Ordering

Kafka allows you to send messages with a key. The key is used to determine which partition a message goes to.

  • Messages with the same key always go to the same partition.
  • This ensures ordering for related messages (e.g., all updates for a specific user).
  • Use kafkaTemplate.send(topic, key, message).
kafkaTemplate.send("user-events", "user-123", "User 123 updated profile");
kafkaTemplate.send("user-events", "user-456", "User 456 logged in");

KafkaTemplate Question

Which of the following statements about KafkaTemplate.send() and its return type is TRUE?

Recap: Sending Messages

Great job! You've learned the essentials of sending messages with Spring Boot's KafkaTemplate:

  • Injection: How to get KafkaTemplate in your services.
  • Basic Send: Using send(topic, message).
  • Synchronous: Blocking with .get() for immediate confirmation.
  • Asynchronous: The preferred method using ListenableFuture and callbacks for efficiency.
  • Keys: How to use message keys for ordering and partitioning.

Next, we'll dive into customizing producer configurations for optimized performance and reliability!

คำถามที่พบบ่อย

บทเรียน “การส่งข้อความด้วย KafkaTemplate” ฟรีหรือไม่

ใช่ — ข้อความเต็มของ “การส่งข้อความด้วย KafkaTemplate” ฟรีให้อ่านที่นี่บนเว็บ เพื่อปฏิบัติแบบโต้ตอบ (ตัวแก้ไขโค้ดในตัวและติวเตอร์ AI ตลอด 24/7) และปลดล็อคส่วนที่เหลือของคอร์ส Advanced Spring Boot 4: Event-Driven Architecture (Kafka) ให้อัปเกรดเป็น CoddyKit PRO คอร์ส Advanced Spring Boot 4: Event-Driven Architecture (Kafka) มีบทเรียนทั้งหมด 4 บทเรียน

คุณจะเรียนรู้อะไรในบทเรียน “การส่งข้อความด้วย KafkaTemplate”

ใช้ KafkaTemplate ของ Spring เพื่อส่งข้อความไปยังท็อปปิก Kafka ด้วยโค้ด รวมถึงแนวทางแบบทำงานพร้อมกันและไม่พร้อมกัน คุณปฏิบัติ Advanced Spring Boot 4: Event-Driven Architecture (Kafka) ด้วยโค้ดที่ใช้งานได้จริงที่คุณเรียกใช้โดยตรงในเบราว์เซอร์ และติวเตอร์ AI ตลอด 24/7 ตอบคำถามของคุณขณะที่คุณไปผ่านบทเรียน

คุณต้องมีประสบการณ์ก่อนที่จะเริ่มเรียน Advanced Spring Boot 4: Event-Driven Architecture (Kafka) หรือไม่

ไม่จำเป็นต้องมีประสบการณ์มาก่อน Advanced Spring Boot 4: Event-Driven Architecture (Kafka) บน CoddyKit ออกแบบมาสำหรับผู้เริ่มต้นไปจนถึงผู้เรียนขั้นสูง คุณสามารถเริ่มต้นที่นี่หรือเริ่มจากตัวแรกและเรียนด้วยความเร็วของคุณเอง นี่คือบทเรียนที่ 2 จากทั้งหมด 4 บทเรียน

บทเรียน “การส่งข้อความด้วย KafkaTemplate” ใช้เวลานานแค่ไหน

บทเรียน CoddyKit ส่วนใหญ่ใช้เวลาประมาณ 5–10 นาที แต่ละบทเรียนจึงสั้นและเป็นแบบโต้ตอบ คุณสามารถก้าวหน้าอย่างต่อเนื่องและกลับมาเรียนต่อจากตรงที่เพิ่งหยุดบนเว็บและแอปได้เลย

ฉันเขียนและรันโค้ดในบทเรียน Advanced Spring Boot 4: Event-Driven Architecture (Kafka) นี้ได้ไหม

ได้ บทเรียน Advanced Spring Boot 4: Event-Driven Architecture (Kafka) ทุกบทมีตัวแก้ไขโค้ดในตัว คุณจึงเขียนและรันโค้ดจริงได้เลยในเบราว์เซอร์ และได้รับข้อเสนอแนะจาก AI ในทันที — ไม่ต้องติดตั้งในเครื่องของคุณ

บทเรียนทั้งหมดในหลักสูตรนี้

  1. การผนวก Spring Kafka Starter
  2. การส่งข้อความด้วย KafkaTemplate
  3. การปรับแต่งการกำหนดค่าผู้ผลิต
  4. การจัดการการตอบกลับและการยืนยันการส่งของผู้ผลิต
← กลับไปที่ Advanced Spring Boot 4: Event-Driven Architecture (Kafka)