Apache Kafka & Stream Processing Fundamentals · Pelajaran

Pengantar Kafka Connect

Pahami arsitektur dan manfaat Kafka Connect untuk mengintegrasikan Kafka dengan sistem eksternal.

Pengantar Kafka Connect adalah pelajaran Apache Kafka & Stream Processing Fundamentals gratis di CoddyKit. Ini adalah pelajaran 1 dari 4. Kamu bisa membaca pelajaran lengkapnya di bawah secara gratis — lalu praktikkan langsung di browser dengan editor kode bawaan dan tutor AI 24/7. Ini adalah bagian dari jalur belajar Apache Kafka & Stream Processing Fundamentals, dan progresmu tersinkronisasi di web dan aplikasi CoddyKit. Kursus Apache Kafka & Stream Processing Fundamentals mencakup 4 pelajaran total.

Bagian dari pelajaran ini belum diterjemahkan dan ditampilkan dalam bahasa Inggris.

Meet Kafka Connect

Kafka Connect is a powerful framework for streaming data between Apache Kafka and other data systems. Think of it as a bridge that automatically moves data for you.

It simplifies the process of getting data into Kafka (from databases, file systems, etc.) and out of Kafka (to data warehouses, search indexes, etc.).

Why Data Integration is Hard

Moving data between different systems can be tricky. You often need to write custom code for each integration, handle errors, ensure data consistency, and scale it as your data grows.

This takes a lot of time and effort! Kafka Connect aims to solve these headaches by providing a standardized, robust way to do it.

Connectors: The Data Bridges

At the heart of Kafka Connect are Connectors. A connector is a ready-to-use component that knows how to interact with a specific external data system.

You don't write custom code for each integration; you just configure a connector. There are two main types:

Source Connectors
Sink Connectors

Source Connectors: Into Kafka

Source connectors are responsible for importing data from an external system into Kafka topics.

Imagine you have a database. A database source connector would continuously read new changes or records from that database and publish them as messages to a Kafka topic.

Examples: JDBC Source Connector (databases), FileStreamSource Connector (files).

Sink Connectors: Out of Kafka

Sink connectors do the opposite: they export data from Kafka topics to an external system.

For instance, a data warehouse sink connector would read messages from a Kafka topic and write them into tables in your data warehouse for analysis.

Examples: JDBC Sink Connector (databases), S3 Sink Connector (cloud storage), Elasticsearch Sink Connector (search).

Why Use Kafka Connect?

Kafka Connect offers several powerful benefits:

No Code Required: Most integrations are configuration-driven.
Scalable: Easily scales to handle large data volumes.
Fault-Tolerant: Automatically recovers from failures.
Distributed: Can run across multiple servers for high availability.
Extensible: Many pre-built connectors, or you can write your own.

How Connect Works

Kafka Connect runs as a cluster of workers. Each worker is a JVM process. These workers host connector tasks.

When you start a connector, Connect distributes its tasks across the available workers. If a worker fails, its tasks are automatically reassigned to other active workers.

Deployment Modes

Kafka Connect can operate in two modes:

Standalone Mode: A single process for development or small-scale use. Not fault-tolerant.
Distributed Mode: Multiple worker processes form a cluster, providing scalability and fault tolerance. Ideal for production environments.

Most production deployments use the distributed mode for reliability.

Simulating Data Inflow

While Kafka Connect handles the heavy lifting, understanding the basic data flow helps. Here's a simple Java program that sends a message to a Kafka topic, similar to what a source connector might automate.

This example shows how data enters a Kafka topic, which Kafka Connect can then manage.

import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerRecord;
import java.util.Properties;

public class SimpleProducer {
  public static void main(String[] args) {
    // 1. Configure producer
    Properties props = new Properties();
    props.put("bootstrap.servers", "localhost:9092");
    props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
    props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

    // 2. Create producer
    try (KafkaProducer<String, String> producer = new KafkaProducer<>(props)) {
      // 3. Create a record
      ProducerRecord<String, String> record = new ProducerRecord<>("my_topic", "hello_key", "Hello from CoddyKit!");

      // 4. Send the record
      producer.send(record);
      System.out.println("Message sent: Hello from CoddyKit!");
    } catch (Exception e) {
      e.printStackTrace();
    }
  }
}

Identify the Connector

You want to move customer order data from a PostgreSQL database into a Kafka topic for real-time processing.

Which type of Kafka Connect connector would you use for this task?

Recap & Next Steps

Great job! In this lesson, we introduced Kafka Connect, a powerful framework for data integration with Kafka.

Kafka Connect simplifies moving data between Kafka and other systems.
Source Connectors bring data into Kafka.
Sink Connectors take data out of Kafka.
It offers scalability, fault tolerance, and reduces custom coding.

Next, we'll dive deeper into configuring and deploying Source Connectors!

Pertanyaan yang Sering Diajukan

Apakah pelajaran “Pengantar Kafka Connect” gratis?

Ya — teks lengkap “Pengantar Kafka Connect” gratis dibaca di sini di web. Untuk praktiknya secara interaktif (editor kode bawaan dan tutor AI 24/7) dan buka sisa kursus Apache Kafka & Stream Processing Fundamentals, upgrade ke CoddyKit PRO. Kursus Apache Kafka & Stream Processing Fundamentals mencakup 4 pelajaran total.

Apa yang akan aku pelajari di “Pengantar Kafka Connect”?

Pahami arsitektur dan manfaat Kafka Connect untuk mengintegrasikan Kafka dengan sistem eksternal. Kamu berlatih Apache Kafka & Stream Processing Fundamentals dengan kode praktik yang langsung kamu jalankan di browser, dan tutor AI 24/7 menjawab pertanyaanmu saat kamu mengerjakan pelajaran ini.

Apakah aku perlu pengalaman untuk memulai Apache Kafka & Stream Processing Fundamentals?

Tidak diperlukan pengalaman sebelumnya. Apache Kafka & Stream Processing Fundamentals di CoddyKit dirancang untuk pemula hingga pelajar tingkat lanjut, jadi kamu bisa memulai di sini atau dari awal dan belajar sesuai kecepatan kamu sendiri. Ini adalah pelajaran 1 dari 4.

Berapa lama pelajaran “Pengantar Kafka Connect” memakan waktu?

Sebagian besar pelajaran CoddyKit memakan waktu sekitar 5–10 menit. Setiap pelajaran ringkas dan interaktif, jadi kamu membuat kemajuan stabil dan melanjutkan dari tempat kamu tinggalkan di web dan aplikasi.

Bisakah aku menulis dan menjalankan kode dalam pelajaran Apache Kafka & Stream Processing Fundamentals ini?

Ya. Setiap pelajaran Apache Kafka & Stream Processing Fundamentals menyertakan editor kode bawaan, jadi kamu menulis dan menjalankan kode nyata langsung di browser dan mendapatkan umpan balik AI instan — tidak diperlukan penyiapan lokal.

Semua pelajaran dalam kursus ini

← Kembali ke Apache Kafka & Stream Processing Fundamentals