Kafka konuları

Apache Kafka'ya Giriş

Mike Metzger

Data Engineering Consultant

Konu nedir?

Konular olayların mantıksal gruplarıdır
- İlişkisel veritabanındaki tabloya benzer
- Olay günlüğü
- İletiler değiştirilemez
- Bir konudaki iletiler okunabilir veya yazılabilir, ancak değiştirilemez
- İletiler yaşa göre silinebilir

Kafka konu görseli.png

Konu oluşturma

Konu oluşturmanın birden çok yolu vardır

bin/kafka-topics.sh betiğini kullanacağız

bin/kafka-topics.sh 
    --bootstrap-server <server> 
    --topic <topicname>
    --create

Örnek

$ bin/kafka-topics.sh --bootstrap-server localhost:9092 \
--topic orders --create

Created topic orders

Diğer varyasyonlar

bin/kafka-topics.sh --create için isteğe bağlı argümanlar
- --replication-factor <x>
  - Konunun çoğaltma faktörünü belirler
- --partitions <x>
  - Bölüm sayısını elle belirtir

Örnek

$ bin\kafka-topics.sh --bootstrap-server localhost:9092 \
--topic orders --create --replication-factor 3 \
--partitions 3

Created topic orders

--describe

bin/kafka-topics.sh --bootstrap-server <server> --topic <topicname> --describe
- Konu yapılandırması hakkında ayrıntıları getirir

Örnek

$ bin/kafka-topics.sh --bootstrap-server localhost:9092 \
   --topic orders --describe

Topic: orders-new TopicId: <topicid> PartitionCount: 3 ReplicationFactor: 1    
  Configs:
    Topic: orders-new    Partition: 0    Leader: 0    Replicas: 0    Isr: 0
    Topic: orders-new    Partition: 1    Leader: 0    Replicas: 0    Isr: 0
    Topic: orders-new    Partition: 2    Leader: 0    Replicas: 0    Isr: 0

Konuları silme

bin/kafka-topics.sh --bootstrap-server <server> --topic <topicname> --delete
- Kafka sunucusundan bir konuyu siler
- Konuyu silmek, içindeki tüm iletileri de siler

Örnek

$ bin/kafka-topics.sh --bootstrap-server localhost:9092
  --topic orders --delete

Hadi pratik yapalım!

Apache Kafka'ya Giriş