Сервис туралыBeta
Cloud Kafka — қолданбалар арасында хабарламаларды жіберуге арналған үлестірілген платформа. Сервистің әрбір экземпляры ақауға төзімді конфигурацияда немесе бір торап конфигурациясында жайылған Apache Kafka кластері болып табылады.
Сервис «жариялау/жазылу» қағидаты бойынша жұмыс істейді: жеткізушілер (producers) хабарламаларды топиктерге жариялайды, ал тұтынушылар (consumers) жаңа хабарламаларды алу үшін сервисті сұрайды. Kafka хабарламаларды оқылғаннан кейін бірден жоймайды, оларды белгіленген уақыт бойы немесе топик партициясындағы деректер көлемі бойынша шекке жеткенге дейін сақтайды. Соның арқасында бір хабарлама әртүрлі тұтынушылармен қажетті рет саны бойынша өңделуі мүмкін.
Сервисті пайдаланудың ықтимал сценарийлері:
- деректерді жүктеу шинасы, соның ішінде деректерді ағындық жүктеу сценарийлерінде;
- қолданбалы жүйелерден метрикаларды, логтарды және хабарламалардың басқа түрлерін жинауға арналған буфер;
- үлестірілген қолданбалардың өзара әрекеттесуіне арналған кезек сервисі.
Cloud Kafka сервисі келесі процестерді автоматтандырады:
- сервис экземпляры үшін инфрақұрылымды жаю;
- кластер ресурстарын тиімді үлестіру;
- сервис экземпляры ресурстарын масштабтау.
Сондай-ақ Cloud Kafka экземплярымен жұмыс істеу үшін Kafka UI құралын жаюға болады. Оның негізгі функциялары:
- Топиктер туралы ақпаратты қарау: партициялар мен репликациялар саны, ағымдағы конфигурация.
- Топиктерді басқару: жасау, конфигурацияны өзгерту, жою.
- Хабарламаларды қарау және басқару: оқу, сүзу және іздеу.
- Тұтынушылармен жұмыс: ығысуды баптау және артта қалуды бақылау.
- Схемаларды басқару: схема мәліметтерін қарау, жаңа схемаларды қосу, сондай-ақ барларын өзгерту немесе жою.
- Өнімділік пен күйді мониторингтеу, сондай-ақ Cloud Kafka сервисі экземпляры компоненттерінің жұмысындағы кідірістер мен қателерді бақылау.