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
