Mengintegrasikan Kafka dengan Layanan Mikro menggunakan Kubernetes

Kafka adalah platform streaming terdistribusi populer yang sering digunakan untuk mengintegrasikan layanan mikro. Layanan mikro adalah layanan kecil dan independen yang bertanggung jawab atas tugas tertentu. Dengan mengintegrasikan Kafka dengan layanan mikro, Anda dapat memisahkan layanan Anda dan membuatnya lebih tahan terhadap kegagalan.

Pada artikel ini, kami akan menunjukkan cara mengintegrasikan Kafka dengan layanan mikro dalam arsitektur kemas menggunakan Kubernetes. Kami akan menggunakan teknologi berikut:

• Kafka
• Kubernetes
• Docker
• Helm

1. Buat kluster Kubernetes

Langkah pertama adalah membuat kluster Kubernetes. Anda dapat menggunakan layanan Kubernetes berbasis cloud seperti Amazon Elastic Kubernetes Service (EKS) atau Google Kubernetes Engine (GKE), atau Anda dapat menginstal Kubernetes di perangkat keras Anda sendiri.

2. Instal Kafka

Setelah Anda membuat cluster Kubernetes, Anda dapat menginstal Kafka. Kami akan menggunakan grafik Helm untuk menginstal Kafka.

Code snippet

helm install kafka bitnami/kafka

Ini akan menginstal Kafka di kluster Kubernetes Anda.

3. Buat layanan mikro

Sekarang kita telah menginstal Kafka, kita dapat membuat layanan mikro. Kami akan menggunakan Dockerfile berikut untuk membuat layanan mikro yang menghasilkan dan menggunakan pesan dari Kafka:

Code snippet

FROM golang:1.17-alpine

WORKDIR /app

COPY go.mod go.sum ./

RUN go mod download

COPY main.go ./

RUN go build -o main

CMD [“./main”]

Kita dapat membuat image Docker menggunakan perintah berikut:

Code snippet

docker build -t my-microservice .

Sekarang kita memiliki image Docker, kita dapat menerapkannya ke Kubernetes. Kami akan menggunakan manifes Kubernetes berikut untuk menerapkan layanan mikro:

Code snippet

apiVersion: apps/v1

kind: Deployment

metadata:

  name: my-microservice

spec:

  replicas: 1

  selector:

    matchLabels:

      app: my-microservice

  template:

    metadata:

      labels:

        app: my-microservice

    spec:

      containers:

      – name: my-microservice

        image: my-microservice

        ports:

        – containerPort: 8080

Kami dapat menggunakan layanan mikro menggunakan perintah berikut:

Code snippet

kubectl apply -f my-microservice.yaml

4. Buat topik Kafka

Sekarang kita memiliki layanan mikro, kita perlu membuat topik Kafka untuk menyimpan pesan yang akan dihasilkan layanan mikro. Kita dapat menggunakan perintah berikut untuk membuat topik Kafka:

kubectl exec -it kafka-0 — kafka-topics –create –topic my-topic –partitions 3 –replication-factor 1

5. Hubungkan layanan mikro ke Kafka

Sekarang kita memiliki topik Kafka, kita perlu menghubungkan layanan mikro ke Kafka. Kita dapat melakukannya dengan memperbarui file konfigurasi layanan mikro. Di file konfigurasi, kita perlu menentukan yang berikut:

Alamat broker Kafka

Nama topik Kafka

Setelah kami memperbarui file konfigurasi, kami dapat memulai ulang layanan mikro.

6. Uji integrasi

Sekarang setelah layanan mikro terhubung ke Kafka, kita dapat menguji integrasinya. Kita dapat melakukan ini dengan mengirimkan pesan ke layanan mikro. Kita dapat menggunakan perintah curl berikut untuk mengirim pesan ke layanan mikro:

Code snippet

curl -X POST http://localhost:8080/message -d ‘{“message”: “Hello, world!”}’

Layanan mikro akan menerima pesan dan mengirimkannya ke Kafka. Kami dapat memverifikasi bahwa pesan telah dikirim ke Kafka dengan menggunakan perintah berikut:

Code snippet

kubectl exec -it kafka-0 — kafka-console-consumer –topic my-topic

Ini akan memulai konsumen konsol Kafka yang akan menggunakan pesan dari topik topik saya. Anda akan melihat pesan yang kami kirim ke layanan mikro.

Kesimpulan

Pada artikel ini, kami menunjukkan kepada Anda cara mengintegrasikan Kafka dengan layanan mikro dalam arsitektur terkontainerisasi menggunakan Kubernetes. Kami menggunakan teknologi berikut:

• Kafka
• Kubernetes
• Docker
• Helm

Dengan mengintegrasikan Kafka dengan layanan mikro, Anda dapat memisahkan layanan Anda dan membuatnya lebih tahan terhadap kegagalan.

Baca Juga :

Gabung dan Belajar Docker and Kubernetes di Inixindo Sekarang!

Hubungan Docker dan Kubernetes Teknologi Kontainer yang Revolusioner