Жылдам бастауBeta
Жылдам бастау сервиспен жұмысты бастауға және оның мүмкіндіктерімен танысуға көмектеседі.
Жылдам бастау қадамдарының барлығын орындағаннан кейін сіз:
- Single конфигурациясындағы Cloud Kafka данасын жасайсыз.
- Топикке (topic) хабарламалар жіберуді және Cloud Kafka данасының топигінен хабарламалар алуды үйренесіз.
-
Өтіңіз VK Cloud жеке кабинетіне.
-
Сервис данасын жасау қажет жобаны таңдаңыз.
-
Деректер платформасы → Сервис даналары бөліміне өтіңіз.
-
Дана жасау батырмасын басыңыз.
-
Конфигурация қадамында:
- Cloud Kafka сервис түрін таңдаңыз.
- 3.5.0 нұсқасын таңдаңыз.
- Жалғыз торап конфигурациясын таңдаңыз.
- Келесі қадам батырмасын басыңыз.
-
Параметрлер қадамында:
-
Данаға атау мен сипаттама беріңіз:
vkcloud-demo-kafkaжәнеБірінші Cloud Kafka данасы. -
Брокер торабының параметрлерін орнатыңыз:
- Виртуалды машинаның түрі:
Standard-2-4. - Диск түрі:
High-IOPS SSD. - Диск өлшемі:
50 ГБ.
- Виртуалды машинаның түрі:
-
Kubernetes кластері: Жаңа кластер жасау тармағын таңдаңыз.
-
Желі: Жаңа желі жасау тармағын таңдаңыз.
-
SDN ретінде Sprut таңдаңыз.
-
Ішкі желі мекенжайы:
10.0.1.0/24көрсетіңіз. -
Қолжетімділік аймағы:
Мәскеу (GZ1). -
Келесі қадам батырмасын басыңыз.
-
-
Тіркелгі деректері қадамында:
-
Kafka-ға қол жеткізуге арналған әкімші логині: мысалы,
kafkaadmin. -
Kafka-ға қол жеткізуге арналған әкімші құпиясөзі: Жасау батырмасын басып, алынған құпиясөзді сақтаңыз.
-
Жасау батырмасын басыңыз.
Операцияның аяқталуын күтіңіз. Cloud Kafka данасын жасау ұзақ уақыт алуы мүмкін.
-
-
Сервис данасымен жұмыс істеу жоспарланған хостта Kafka консольдік клиенттеріне қол жеткізіңіз:
Linux (bash) / macOS (zsh)-
Хостта Java 11 немесе одан жоғары нұсқасы орнатылғанына көз жеткізіңіз:
java --versionЕгер шығыста
Command 'java' not foundболса немесе нұсқа ескірген болса, мысалы, OpenJDK Java Development Kit (JDK) орнатыңыз. JDK-ны толықтай да, тек Java Runtime Environment (JRE) нұсқасын да орнатуға болады.Ubuntu 22.04 LTS үшін
aptарқылы OpenJDK 11 (тек JRE) орнату мысалы:sudo apt update && sudo apt install openjdk-11-jre -
Kafka 3.5.0 нұсқасының дистрибутиві бар архивті жүктеп алыңыз. Сервис данасындағы және хосттағы Kafka нұсқалары сәйкес келуі керек. cURL көмегімен дистрибутивті жүктеу пәрменінің мысалы:
curl -O https://archive.apache.org/dist/kafka/3.5.0/kafka_2.13-3.5.0.tgz -
Архивті ашып, ашылған файлдар директориясына өтіңіз:
tar -xzf kafka_2.13-3.5.0.tgz && cd kafka_2.13-3.5.0 -
Консольдік producer клиенті мен consumer клиентінің нұсқасын алыңыз:
bin/kafka-console-producer.sh --versionbin/kafka-console-consumer.sh --versionНұсқаның сәтті шығуы клиенттердің дұрыс жұмыс істеп тұрғанын білдіреді.
-
Келесі мазмұнмен
client-sasl-ssl.propertiesконфигурациялық файлын жасаңыз:security.protocol=SASL_SSLБұл файлда producer клиенті мен consumer клиентінен сервис данасында SASL_SSL протоколы арқылы аутентификациядан өтуді талап ететін баптау бар.
-
-
Сервис данасына қосылу үшін bootstrap-сервердің мекенжайын алыңыз:
- Өтіңіз VK Cloud жеке кабинетіне.
- Сервис данасы орналасқан жобаны таңдаңыз.
- Деректер платформасы → Сервис даналары бөліміне өтіңіз.
vkcloud-demo-kafkaкластерінің атауын басып, оның бетін ашыңыз.- Жалпы ақпарат қойындысына өтіңіз.
- Bootstrap параметрінен мекенжайды жазып алыңыз.
-
Консольдік клиент жұмыс істейтін жеке терминал сессиясын жасаңыз.
-
Осы сессияда consumer клиентін іске қосып,
testтопигін дереккөз ретінде көрсетіңіз. Consumer клиенті бұрын алынған bootstrap-сервер мекенжайын және конфигурация файлын пайдаланып Cloud Kafka данасына қосылады да, топиктен хабарламаларды үздіксіз оқып, шығарып отырады. Жаңа топик оған бірінші рет жүгінген кезде автоматты түрде жасалады.Ол үшін мына пәрменді орындаңыз:
bin/kafka-console-consumer.sh --bootstrap-server kafka-bootstrap.example.com:9093 --consumer.config client-sasl-ssl.properties --topic test -
Басқа консольдік клиент жұмыс істейтін тағы бір терминал сессиясын жасаңыз.
-
Осы сессияда producer клиентін іске қосып,
testтопигін қабылдағыш ретінде көрсетіңіз. Producer клиенті бұрын алынған bootstrap-сервер мекенжайын және конфигурация файлын пайдаланып Cloud Kafka данасына қосылады да, енгізілген хабарламаларды топикке жібереді.Ол үшін мына пәрменді орындаңыз:
bin/kafka-console-producer.sh --broker-list kafka-bootstrap.example.com:9093 --producer.config client-sasl-ssl.properties--topic test -
Producer клиенті бар терминал сессиясында сынақ хабарламасын енгізіп, содан кейін Enter пернесін басыңыз:
This is the test message. -
Consumer клиенті бар терминал сессиясында жіберілген сынақ хабарламасының көрсетіліп тұрғанын тексеріңіз:
This is the test message.Хабарламаның болуы Cloud Kafka данасының дұрыс жұмыс істеп тұрғанын білдіреді.
-
Екі терминал сессиясында да CTRL+C пернелер тіркесімін басып, клиенттердің жұмысын аяқтаңыз.
Cloud Kafka данасы тарифтеледі және есептеу ресурстарын тұтынады. Егер ол сізге енді қажет болмаса, оны жойыңыз.
Сондай-ақ client-sasl-ssl.properties конфигурациялық файлын және жүктелген Kafka дистрибутивін жоя аласыз.