ਕਦਮ 1: ਲਈ ਕਾਫਕਾ ਲਾਇਬ੍ਰੇਰੀ ਸਥਾਪਿਤ ਕਰੋ Node.js
terminal ਆਪਣੀ Node.js ਪ੍ਰੋਜੈਕਟ ਡਾਇਰੈਕਟਰੀ ਵਿੱਚ ਇੱਕ ਖੋਲ੍ਹੋ .
ਲਾਇਬ੍ਰੇਰੀ ਨੂੰ ਇੰਸਟਾਲ ਕਰਨ ਲਈ ਹੇਠ ਲਿਖੀ ਕਮਾਂਡ ਚਲਾਓ kafkajs
, Node.js ਲਈ ਇੱਕ ਲਾਇਬ੍ਰੇਰੀ Apache Kafka: npm install kafkajs
.
Producer ਕਦਮ 2: ਅੰਦਰ ਦੇ ਨਾਲ ਸੁਨੇਹੇ ਭੇਜਣਾ Node.js
ਲਾਇਬ੍ਰੇਰੀ ਨੂੰ ਆਯਾਤ ਕਰੋ kafkajs
ਅਤੇ Kafka Broker ਸੰਰਚਨਾ ਨੂੰ ਪਰਿਭਾਸ਼ਿਤ ਕਰੋ:
ਸੁਨੇਹੇ ਭੇਜਣ ਲਈ ਇੱਕ ਬਣਾਓ producer, ਅਤੇ ਇੱਕ ਨੂੰ ਇੱਕ ਸੁਨੇਹਾ ਭੇਜੋ topic:
Consumer ਕਦਮ 3: ਅੰਦਰ ਦੇ ਨਾਲ ਸੁਨੇਹੇ ਪ੍ਰਾਪਤ ਕਰਨਾ Node.js
ਲਾਇਬ੍ਰੇਰੀ ਨੂੰ ਆਯਾਤ ਕਰੋ kafkajs
ਅਤੇ Kafka Broker ਸੰਰਚਨਾ ਨੂੰ ਪਰਿਭਾਸ਼ਿਤ ਕਰੋ(ਜੇਕਰ ਪਹਿਲਾਂ ਹੀ ਨਹੀਂ ਕੀਤਾ ਗਿਆ ਹੈ):
consumer ਕਿਸੇ ਖਾਸ ਤੋਂ ਸੁਨੇਹੇ ਪ੍ਰਾਪਤ ਕਰਨ ਲਈ ਇੱਕ ਬਣਾਓ topic:
ਨੋਟ: 'your-client-id'
, 'broker1:port1'
, 'your-topic'
, ਅਤੇ 'your-group-id'
ਆਪਣੀ ਅਸਲ ਪ੍ਰੋਜੈਕਟ ਜਾਣਕਾਰੀ ਨਾਲ ਮੁੱਲ ਬਦਲੋ ।
ਸੰਰਚਨਾ ਵਿਕਲਪਾਂ ਅਤੇ ਕਾਰਜਕੁਸ਼ਲਤਾਵਾਂ ਬਾਰੇ ਵਧੇਰੇ ਜਾਣਕਾਰੀ ਲਈ ਅਧਿਕਾਰਤ ਦਸਤਾਵੇਜ਼ਾਂ Apache Kafka ਅਤੇ ਲਾਇਬ੍ਰੇਰੀ ਦਾ ਹਵਾਲਾ ਦੇਣਾ ਯਕੀਨੀ ਬਣਾਓ। kafkajs