Apache Kafka
Клацніть правою кнопкою в дереві ▸ Додати ▸ Запит Kafka.
Спільна конфігурація
Section titled “Спільна конфігурація”| Поле | Роль |
|---|---|
| URL | Перелік брокерів через кому: hote1:9092,hote2:9092 — увесь рядок обчислюється через Handlebars перед розбиттям |
| Ідентифікатор клієнта | clientId, який оголошується брокерам |
| Тема | Тема, незалежно від режиму |
| Режим | produce, consume або browse |
Автентифікація
Section titled “Автентифікація”| Поле | Значення |
|---|---|
| Механізм SASL | none, plain, scram-sha-256, scram-sha-512 |
| Користувач SASL / Пароль SASL | Пароль приймає значення типу «Секрет» |
| TLS | Вмикається незалежно — брокер із TLS без SASL працює з механізмом none |
Режим produce
Section titled “Режим produce”Ключ, значення, заголовки запису і, за бажанням, партиція. Без явної партиції застосовується типовий розподільник клієнтської бібліотеки. Відповідь повертає метадані записаного запису: тему, партицію, зміщення.
Режим consume
Section titled “Режим consume”| Поле | Роль |
|---|---|
| Група | groupId споживача |
| Початкове зміщення | earliest, latest або specific |
| Конкретне зміщення | Рядок — зміщення Kafka є 64-бітними цілими |
| Партиції | Фільтр на боці клієнта: розподіл партицій і далі виконує група |
Режим browse
Section titled “Режим browse”Оглядає партицію без групи споживачів: Restorm бере обмежену кількість повідомлень, а потім від’єднується. У цьому режимі партиція обов’язкова.
Це правильний інструмент, щоб подивитися, що є в темі, не створюючи групи й не зсуваючи зміщень.
У сценарії
Section titled “У сценарії”- Виробництво Kafka — одинична дія, повертає метадані запису;
- Споживання Kafka — підписується через групу споживачів і генерує подію на кожне повідомлення;
- Закриття з’єднання Kafka — зупиняє споживання.
Див. З’єднання та потоки.
Фрагменти коду
Section titled “Фрагменти коду”П’ять цілей: JavaScript (kafkajs — для виробництва та споживання) і kcat
(виробництво, споживання, огляд без групи).