Apache Kafka

Kliknięcie prawym przyciskiem w drzewie ▸ Dodaj ▸ Żądanie Kafka.

Konfiguracja wspólna

Pole	Rola
URL	Lista brokerów oddzielonych przecinkami: hote1:9092,hote2:9092 — cały ciąg jest rozwiązywany przez Handlebars przed podziałem
Identyfikator klienta	Wartość clientId ogłaszana brokerom
Temat	Temat, niezależnie od trybu
Tryb	produce, consume lub browse

Uwierzytelnianie

Pole	Wartości
Mechanizm SASL	none, plain, scram-sha-256, scram-sha-512
Użytkownik SASL / Hasło SASL	Hasło przyjmuje wartość typu Sekret
TLS	Można włączyć niezależnie — broker z TLS bez SASL działa z mechanizmem none

Tryb produce

Klucz, wartość, nagłówki rekordu oraz opcjonalnie partycja. Bez wskazania partycji obowiązuje domyślny partycjoner biblioteki klienckiej. Odpowiedź zwraca metadane zapisanego rekordu: temat, partycję i offset.

Tryb consume

Pole	Rola
Grupa	Wartość groupId konsumenta
Offset początkowy	earliest, latest lub specific
Konkretny offset	Ciąg znaków — offsety Kafki są 64-bitowymi liczbami całkowitymi
Partycje	Filtr po stronie klienta: przydział partycji nadal wykonuje grupa

Tryb browse

Umożliwia inspekcję partycji bez grupy konsumentów: Restorm pobiera z niej ograniczoną liczbę wiadomości, a następnie się rozłącza. W tym trybie partycja jest obowiązkowa.

To właściwe narzędzie, aby zobaczyć, co znajduje się w temacie, bez tworzenia grupy i bez przesuwania offsetu.

W scenariuszu

• Produkcja Kafka — akcja pojedyncza, zwraca metadane rekordu;
• Konsumpcja Kafka — subskrybuje przez grupę konsumentów i emituje jedno zdarzenie na każdą wiadomość;
• Zamknięcie połączenia Kafka — zatrzymuje konsumpcję.

Zob. Połączenia i strumienie.

Fragmenty kodu

Pięć celów: JavaScript (kafkajs, w trybie produkcji i konsumpcji) oraz kcat (produkcja, konsumpcja, przeglądanie bez grupy).