Twitter Youtube Github
Burak Kutbay'ın Kişisel Blog'u |

Type and hit Enter to search

  • Eğitim
  • Quarkus
  • Spring Cloud
  • Spring Boot
  • Spring JDBC Template
  • Spring MVC
  • Spring Core
  • Spring Örnekleri
  • Hibernate
  • Java Server Pages
  • Java Server Faces
  • PrimeFaces
  • Servlet
  • JDBC
  • JSTL
  • Java 8
  • / Diğer
    • Ünlü Bilişimciler
    • C Sharp
    • Kütüphane
    • Makale
Apache KafkaDevOps

Docker ile Apache Kafka Kurulumu ve Kullanımı

Paylaş

Bu yazıda Docker aracılığı ile bilgisayarımızda Apache Kafka nasıl kurulur? Topic nasıl oluşturulur, Broker’ı başlatma ve Broker’a mesaj gönderip, mesajı okuma işlemleri nasıl olmaktadır gibi konulardan bahsedeceğim.

İçindekiler

  • Docker Dosyası Oluşturma ve Kurulumu
  • Topic Oluşturmak
  • Kafkayı Durdurmak

İlgini Çekebilir: Spring Boot Apache Kafka Uygulaması

Docker Dosyası Oluşturma ve Kurulumu

version: '3'
services:
  zookeeper:
    image: confluentinc/cp-zookeeper:7.0.1
    container_name: zookeeper
    environment:
      ZOOKEEPER_CLIENT_PORT: 2181
      ZOOKEEPER_TICK_TIME: 2000
  broker:
    image: confluentinc/cp-kafka:7.0.1
    container_name: broker
    ports:
      - "9092:9092"
    depends_on:
      - zookeeper
    environment:
      KAFKA_BROKER_ID: 1
      KAFKA_ZOOKEEPER_CONNECT: 'zookeeper:2181'
      KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,PLAINTEXT_INTERNAL:PLAINTEXT
      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://localhost:9092,PLAINTEXT_INTERNAL://broker:29092
      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
      KAFKA_TRANSACTION_STATE_LOG_MIN_ISR: 1
      KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR: 1
Code language: JavaScript (javascript)

docker-compose.yml adında bu docker dosyamızı kayıt edelim.

Ardından docker compose up -d diyerek Kafka Broker’ımızın inmesini bekliyoruz. Ve sonunda aşağıdaki mesajı aldıktan sonra tamamlanmış olduğunu anlıyoruz.

Creating zookeeper ... done
Creating broker    ... done

Apache Kafka Docker’ımızı çalıştırdık.

docker ps

yazarak şu an çalışıp çalışmadığını kontrol edebiliriz. Eğer çalışıyor olarak gözüküyorsa diğer işlemlere devam edebiliriz.

Topic Oluşturmak

Kafka Broker’imize topic oluşturmak için ise çalışan Docker imajının içerisine girerek kafka cli üzerinden topic oluşturacağız. Çalışan Kafka imajımızın içerisine girebilmek için exec komutundan faydalanıyoruz.

docker exec broker \                                                                                                                                                ✔  17:21:10
kafka-topics --bootstrap-server broker:9092 \
             --create \
             --topic exampletopicCode language: CSS (css)

exampletopic adında bir topic oluşturmak için çalışan ilgili broker’a create etmek için yukarıdaki komutu kullanıyoruz.

Topic’in oluştuğunu anlamak için ise aşağıdaki mesajı almalıyız.

Created topic exampletopic.

Kafkayı Durdurmak

Çalışan Kafka Broker Docker imajımızı durdurmak için ise aşağıdaki komutu yazmamız yeterli olmaktadır. Bu komutu yazarken docker dosyamızın içerisinde bulunduğu konumda yazmalıyız. Aksi takdirde container id’ye göre kapatmamız gerekir.

docker-compose down

Tags:

apache kafkadockerdocker kurulumukafka broker kurulumukafka kurulumu

Paylaş

Diğer Yazılar

Java Day İstanbul 2022
Previous

#JavaDayIstanbul 2022 Notlarım

Spring Cloud Open Feign Nedir Kullanım Örneği
Next

Spring Cloud OpenFeign Nedir? OpenFeign ile Servisler Arası İletişim Kurmak

Next
Spring Cloud Open Feign Nedir Kullanım Örneği
04 Haziran 2022

Spring Cloud OpenFeign Nedir? OpenFeign ile Servisler Arası İletişim Kurmak

Previews
30 Mayıs 2022

#JavaDayIstanbul 2022 Notlarım

Java Day İstanbul 2022

No Comment! Be the first one.

Bir cevap yazın Cevabı iptal et

E-posta hesabınız yayımlanmayacak. Gerekli alanlar * ile işaretlenmişlerdir

İlgini Çekebilir

JIB Plugin Dockerize Kullanımı

Jib ile Java Projelerini Verimli ve Hızlı Dockerize Etmek

blank

Docker Ports are not available: listen tcp bind: An attempt was made to access a socket in a way forbidden by its access permissions Hatası Çözümü

Burak Kutbay'ın Kişisel Blog'u |

© 2008 - ∞, Her hakkı saklıdır.

Link

  • Hakkımda
  • İletişim
  • Arşiv

Kategori

Cloud
Amazon Web Services
Vue.js
Gradle
Node.js
Android
Struts
Redis
Röportaj
Spring Data
Spring Cloud Stream
XCode
Debezium
Mikroservis Mimarisi
Video
Spring Native
iPhone Uygulama Geliştirme
Objective C
JPA
Spring Security
PostgreSQL
Apache Kafka
Git
Servlet
Yaptığım Projeler
Maven
Design Patterns
DevOps
Linux
RabbitMQ
PrimeFaces
JDBC
Spring Jdbc Template
Spring
Spring MVC
Manset
Google
Spring Cloud
OCA Java SE 8
Spring Core
Quarkus
Microsoft
Tanıyalım
Veritabanı
Java SE
Hibernate
Teknoloji
Okuduğum Kitaplar
Java Server Faces
Yazılım Mühendisliği
C Sharp
Spring Boot
Java
Günlüğüm
Java Server Page
Makale

Takip Et

Twitter Youtube Github
  • Eğitim
  • Quarkus
  • Spring Cloud
  • Spring Boot
  • Spring JDBC Template
  • Spring MVC
  • Spring Core
  • Spring Örnekleri
  • Hibernate
  • Java Server Pages
  • Java Server Faces
  • PrimeFaces
  • Servlet
  • JDBC
  • JSTL
  • Java 8
  • / Diğer
    • Ünlü Bilişimciler
    • C Sharp
    • Kütüphane
    • Makale