Kafka ile Mikroservisler: \u00c7oklu Konularla \u00c7ift Y\u00f6nl\u00fc \u0130leti\u015fim (KRaft)<\/p>\n
Merhaba! Fatih Soysal olarak, bug\u00fcn size da\u011f\u0131t\u0131k sistemlerdeki ileti\u015fimin \u00f6nemli bir par\u00e7as\u0131 olan Kafka’y\u0131 ve mikroservis mimarilerinde nas\u0131l kullan\u0131labilece\u011fini anlataca\u011f\u0131m. \u00d6zellikle, \u00e7oklu konularla \u00e7ift y\u00f6nl\u00fc ileti\u015fim sa\u011flayan KRaft mimarisini detayl\u0131 olarak inceleyece\u011fiz. Bu mimari, karma\u015f\u0131k sistemlerde daha esnek ve \u00f6l\u00e7eklenebilir bir ileti\u015fim sa\u011flar.<\/p>\n
\u00d6ncelikle, mikroservis mimarisinde neden Kafka’ya ihtiya\u00e7 duydu\u011fumuzu anlamak \u00f6nemlidir. Mikroservisler birbirinden ba\u011f\u0131ms\u0131z olarak \u00e7al\u0131\u015f\u0131r ve farkl\u0131 teknolojiler kullanabilir. Bu durum, servisler aras\u0131 ileti\u015fimi zorla\u015ft\u0131r\u0131r. Bunun i\u00e7in g\u00fcvenilir, \u00f6l\u00e7eklenebilir ve asenkron bir ileti\u015fim arac\u0131 gereklidir. \u0130\u015fte bu noktada Kafka devreye girer.<\/p>\n
Kafka, da\u011f\u0131t\u0131lm\u0131\u015f bir yay\u0131n-abone mesaj kuyru\u011fu sistemidir. Mesajlar\u0131 kal\u0131c\u0131 olarak depolar ve t\u00fcketicilerin kendi h\u0131zlar\u0131nda mesajlar\u0131 t\u00fcketmelerini sa\u011flar. Bu, sistemin y\u00fcksek y\u00fck alt\u0131nda bile kararl\u0131 kalmas\u0131n\u0131 garantiler. Ayr\u0131ca, Kafka’n\u0131n \u00f6l\u00e7eklenebilirli\u011fi, b\u00fcy\u00fck miktarda veriyi i\u015fleyebilme yetene\u011fi sayesinde, mikroservis mimarileri i\u00e7in ideal bir \u00e7\u00f6z\u00fcm haline gelir.<\/p>\n
KRaft, Kafka tabanl\u0131 bir mimari olup, mikroservisler aras\u0131nda \u00e7ift y\u00f6nl\u00fc ileti\u015fim sa\u011flar. Her mikroservis, kendi olaylar\u0131n\u0131 yay\u0131nlamak i\u00e7in bir konuya (\u00f6rne\u011fin, “UserCreated”) ve di\u011fer mikroservislerden gelen olaylar\u0131 dinlemek i\u00e7in bir veya daha fazla konuya abone olur (\u00f6rne\u011fin, “OrderPlaced”). Bu yakla\u015f\u0131m, sistemin daha mod\u00fcler ve ba\u011f\u0131ms\u0131z olmas\u0131n\u0131 sa\u011flar.<\/p>\n
\u00d6rne\u011fin, bir e-ticaret uygulamas\u0131nda, kullan\u0131c\u0131 kay\u0131t i\u015flemi sonras\u0131 “UserCreated” konuya bir mesaj yay\u0131nlan\u0131r. \u00d6deme servisi bu konuyu dinler ve yeni kullan\u0131c\u0131 i\u00e7in bir \u00f6deme profili olu\u015fturur. Benzer \u015fekilde, sipari\u015f olu\u015fturma i\u015flemi sonras\u0131nda “OrderPlaced” konuya mesaj yay\u0131nlan\u0131r ve di\u011fer servisler bu mesaj\u0131 kullanarak ilgili i\u015flemleri ger\u00e7ekle\u015ftirir. Ancak bu sadece tek y\u00f6nl\u00fc ileti\u015fimdir. KRaft’\u0131n g\u00fcc\u00fc \u00e7ift y\u00f6nl\u00fc ileti\u015fimde sakl\u0131d\u0131r.<\/p>\n
\u00c7ift y\u00f6nl\u00fc ileti\u015fim i\u00e7in, her mikroservis, kendisi i\u00e7in \u00f6zel bir konuya sahip olur. Di\u011fer mikroservisler, bu konuya mesaj g\u00f6ndererek do\u011frudan ileti\u015fim kurabilir. Bu durum, \u00f6zellikle senkronizasyon gerektiren i\u015flemler i\u00e7in olduk\u00e7a faydal\u0131d\u0131r. \u00d6rne\u011fin, \u00f6deme servisi, \u00f6deme ba\u015far\u0131l\u0131 olduktan sonra, sipari\u015f servisine onay mesaj\u0131 g\u00f6ndermek i\u00e7in bu y\u00f6ntemi kullanabilir.<\/p>\n
KRaft mimarisi, bir\u00e7ok avantaj sunar: Esneklik, \u00f6l\u00e7eklenebilirlik, g\u00fcvenilirlik ve ba\u011f\u0131ms\u0131z geli\u015ftirme. Her mikroservis, kendi konular\u0131n\u0131 kullanarak ba\u011f\u0131ms\u0131z olarak geli\u015ftirilebilir ve da\u011f\u0131t\u0131labilir. Bu durum, geli\u015ftirme s\u00fcre\u00e7lerini h\u0131zland\u0131r\u0131r ve daha ba\u011f\u0131ms\u0131z ekiplere olanak tan\u0131r. Sistemin \u00f6l\u00e7eklenebilirli\u011fi, Kafka’n\u0131n da\u011f\u0131t\u0131lm\u0131\u015f yap\u0131s\u0131 sayesinde olduk\u00e7a y\u00fcksektir. Mesajlar\u0131n kal\u0131c\u0131 olarak depolanmas\u0131, sistemin y\u00fcksek y\u00fck alt\u0131nda bile kararl\u0131 kalmas\u0131n\u0131 sa\u011flar.<\/p>\n
\n\/\/ Java ile Kafka Producer \u00f6rne\u011fi (basitle\u015ftirilmi\u015f)\n\/\/ ... Kafka k\u00fct\u00fcphaneleri import edilir ...\n\nProperties props = new Properties();\nprops.put(\"bootstrap.servers\", \"localhost:9092\");\nprops.put(\"key.serializer\", \"org.apache.kafka.common.serialization.StringSerializer\");\nprops.put(\"value.serializer\", \"org.apache.kafka.common.serialization.StringSerializer\");\n\nProducer<String, String> producer = new KafkaProducer<String, String>(props);\n\nProducerRecord<String, String> record = new ProducerRecord<String, String>(\"UserCreated\", \"Yeni kullan\u0131c\u0131 olu\u015fturuldu!\");\nproducer.send(record);\n\nproducer.close();\n<\/code><\/pre>\nBu sadece basit bir \u00f6rnektir. Ger\u00e7ek d\u00fcnya uygulamalar\u0131nda, daha karma\u015f\u0131k konfig\u00fcrasyonlar ve hata y\u00f6netimi mekanizmalar\u0131 kullanman\u0131z gerekecektir.<\/p>\n