Lati inu iwe ti a pese, ṣe akojọ awọn API pataki ni Kafka. Fi àlàfo yà wọ́n.
Context:Kafka máa ń tọ́jú àwọn ìsọfúnni tó ṣe kókó tó sì níye lórí tí wọ́n ń jáde látara àwọn ìgbésẹ̀ tí a ń pè ní àwọn olùtúnyẹ̀wò. A lè pín àwọn ìsọfúnni náà sí "ìpín" ọ̀tọ̀ọ̀tọ̀ nínú "àwọn kókó" ọ̀tọ̀ọ̀tọ̀. Ninu apa kan, awọn ifiranṣẹ ni a paṣẹ ni ibamu nipasẹ awọn idasilẹ wọn (ipin ti ifiranṣẹ laarin apa kan), ati itọka ati fipamọ papọ pẹlu timestamp kan. Àwọn ìgbésẹ̀ míràn tí a ń pè ní "olùgbédè" lè ka àwọn ìsọfúnni láti inú àwọn àlàfo. Fun sisẹ ṣiṣan, Kafka nfunni awọn ṣiṣan API ti o fun laaye kikọ awọn ohun elo Java ti o jẹ data lati Kafka ati kọ awọn esi pada si Kafka. Apache Kafka tun ṣiṣẹ pẹlu awọn ọna ṣiṣe ṣiṣan ṣiṣan ita bi Apache Apex, Apache Beam, Apache Flink, Apache Spark, Apache Storm, ati Apache NiFi.  Kafka nṣiṣẹ lori ẹgbẹ kan ti ọkan tabi diẹ ẹ sii awọn olupin (ti a npe ni alagbata), ati awọn ipin ti gbogbo awọn koko-ọrọ ni a pin kaakiri awọn nodes ẹgbẹ. Pẹlupẹlu, awọn ipin ti wa ni replicated si awọn alagbata pupọ. Ẹ̀rọ yìí jẹ́ kí Kafka lè fi àwọn ìsọfúnni ránṣẹ́ lọ́nà tí kò ní jẹ́ kí àṣìṣe wáyé, ó sì ti jẹ́ kó lè rọ́pò àwọn ètò ìsọfúnni tí wọ́n ń lò tẹ́lẹ̀ bíi Java Message Service (JMS), Advanced Message Queuing Protocol (AMQP), àti bẹ́ẹ̀ bẹ́ẹ̀ lọ.  Kafka ṣe atilẹyin awọn oriṣi meji ti awọn akori: deede ati ti o nipọn. A le ṣe agbekalẹ awọn akọle deede pẹlu akoko idaduro tabi aaye ti o ni opin. Bí àwọn àkọsílẹ̀ bá wà tí wọ́n ti dàgbà ju àkókò ìpamọ́ tí a pàṣẹ tàbí bí àyè tí a pàṣẹ fún ìpín kan bá ti kọjá, Kafka ní àṣẹ láti pa àwọn ìpamọ́ tí ó ti pẹ́ kí ó lè tú àyè ìpamọ́ sílẹ̀. Nipa aiyipada, awọn akori ti wa ni iṣeto pẹlu akoko idaduro ti awọn ọjọ 7, ṣugbọn o tun ṣee ṣe lati tọju data laipe. Nípa àwọn kókó tí a ti kó jọpọ̀, àwọn àkọsílẹ̀ kì í pé ní ìbámu pẹ̀lú ààlà àkókò tàbí àyè. Kàkà bẹ́ẹ̀, Kafka máa ń wo àwọn ìsọfúnni tó bá dé lẹ́yìn ìgbà náà gẹ́gẹ́ bí àtúnṣe sí àwọn ìsọfúnni tó ti wà tẹ́lẹ̀ pẹ̀lú kókó kan náà, ó sì máa ń ṣe ìdánilójú pé òun ò ní pa àwọn ìsọfúnni tó ṣẹ̀ṣẹ̀ jáde tì. Àwọn oníṣe lè pa àwọn ìsọfúnni rẹ́ pátápátá nípa kíkọ ohun tí a ń pè ní ìsọfúnni òkúta ibojì pẹ̀lú null-value fún kókó pàtó kan.  Àwọn API pàtàkì márùn-ún ló wà nínú Kafka:  API Olùgbéejáde <unk> Fàyè gba ohun èlò láti tẹ àwọn ìsọfúnni àkọsílẹ̀ jáde. API Olumulo <unk> Gba ohun elo laaye lati ṣe alabapin si awọn akọle ati awọn ilana ṣiṣan ti awọn igbasilẹ. Connector API <unk> Ṣiṣẹ awọn olupilẹṣẹ ati awọn API alabara ti o le tunlo ti o le sopọ awọn akọle si awọn ohun elo ti o wa tẹlẹ. Awọn ṣiṣan API <unk> API yii ṣe iyipada awọn ṣiṣan wiwọle si abajade ati ṣe agbejade abajade. Admin API <unk> Ti a lo lati ṣakoso awọn akọle Kafka, awọn alagbata, ati awọn nkan Kafka miiran. Awọn olumulo ati olupilẹṣẹ awọn API ti wa ni decoupled lati awọn iṣẹ-ṣiṣe pataki ti Kafka nipasẹ ilana ifiranṣẹ ti o wa labẹ. Eyi jẹ ki kikọ awọn ipele API ti o ni ibamu ni eyikeyi ede siseto ti o munadoko bi awọn Java APIs ti o wa pẹlu Kafka. Ise agbese Apache Kafka n ṣetọju atokọ ti iru awọn API ẹnikẹta.
API Olùgbéejáde, API Olùgbéejáde, API Olùso, API Ìṣàn, API Olùdarí