1. lépés: Telepítse a Kafka Library for Node.js
Nyisson meg egyet terminal a projektkönyvtárában Node.js.
Futtassa a következő parancsot a könyvtár telepítéséhez kafkajs
, egy Node.js könyvtár a következőhöz Apache Kafka: npm install kafkajs
.
2. lépés: Üzenetek küldése a Producer bemenettel Node.js
Importálja a kafkajs
könyvtárat és adja meg a Kafka Broker konfigurációt:
Hozzon létre egy producer üzenetet, és küldjön üzenetet a következő címre topic:
3. lépés: Üzenetek fogadása Consumer a bejövővel Node.js
Importálja a kafkajs
könyvtárat és adja meg a Kafka Broker konfigurációt(ha még nem tette meg):
Hozzon létre egy consumer üzenetet egy adott személytől topic:
Megjegyzés: Cserélje ki az olyan értékeket, mint 'your-client-id'
a, 'broker1:port1'
, 'your-topic'
, és 'your-group-id'
a tényleges projektinformációkkal.
A konfigurációs opciókkal és funkciókkal kapcsolatos további információkért tekintse meg a hivatalos dokumentációt Apache Kafka és a könyvtárat. kafkajs