Krok 1: Nainstalujte knihovnu Kafka pro Node.js
Otevřete a terminal v Node.js adresáři projektu.
Spuštěním následujícího příkazu nainstalujte kafkajs
knihovnu, Node.js knihovnu pro Apache Kafka: npm install kafkajs
.
Krok 2: Odesílání zpráv pomocí Producer in Node.js
Importujte kafkajs
knihovnu a definujte Kafka Broker konfiguraci:
Vytvořte a producer odešlete zprávy a odešlete zprávu na topic:
Krok 3: Příjem zpráv pomocí Consumer in Node.js
Importujte kafkajs
knihovnu a definujte Kafka Broker konfiguraci(pokud jste tak již neučinili):
Vytvořte consumer pro příjem zpráv od konkrétního topic:
Poznámka: Hodnoty jako 'your-client-id'
, 'broker1:port1'
, 'your-topic'
a 'your-group-id'
nahraďte skutečnými informacemi o projektu.
Další informace o možnostech konfigurace a funkcích najdete v oficiální dokumentaci Apache Kafka a knihovně. kafkajs