### Getting Started · KafkaJS
Install KafkaJS using :
```
yarn add kafkajs
npm install kafkajs
```
Let's start by instantiating the KafkaJS client by…
kafka js is a native library without any node js binding so there will be no compatibility issues and no runtime errors
So with kafka js, lots of problems with integration are no more for the developers
```javascript
const { Kafka } = require('kafkajs')
// This creates a client instance that is configured to connect to the Kafka broker provided by
// the environment variable KAFKA_BOOTSTRAP_SERVER
const kafka = new Kafka({
clientId: 'qa-topic',
brokers: ['xxxxxxxxx.confluent.cloud:9092'],
ssl: true,
logLevel: 2,
sasl: {
mechanism: 'plain',
username: 'xxxxxxxxxxx',
password: 'xxxxxxxxxx'
}
})
const producer = kafka.producer()
producer.on('producer.connect', () => {
console.log(`KafkaProvider: connected`);
});
producer.on('producer.disconnect', () => {
console.log(`KafkaProvider: could not connect`);
});
producer.on('producer.network.request_timeout', (payload) => {
console.log(`KafkaProvider: request timeout ${payload.clientId}`);
});
const run = async () => {
// Producing
await producer.connect()
await producer.send({
topic: 'supplier-ratings',
messages: [
{
value: Buffer.from(JSON.stringify(
{
"event_name": "QA",
"external_id": user_uuiD,
"payload": {
"supplier_id": i.supplier_id,
"assessment": {
"performance": 7,
"quality": 7,
"communication": 7,
"flexibility": 7,
"cost": 7,
"delivery": 6
}
},
"metadata": {
"user_uuid": "5a12cba8-f4b5-495b-80ea-d0dd5d4ee17e"
}
}
))
},
],
})
Consuming
await consumer.connect()
await consumer.subscribe({ topic: 'test-topic', fromBeginning: true })
await consumer.run({
eachMessage: async ({ topic, partition, message }) => {
console.log({
partition,
offset: message.offset,
value: message.value.toString(),
})
},
})
}
run().catch(console.error)
```
References
* [https://docs.confluent.io/5.5.1/kafka/introduction.html](https://docs.confluent.io/5.5.1/kafka/introduction.html)
* [https://aws.amazon.com/msk/what-is-kafka/](https://aws.amazon.com/msk/what-is-kafka/)
* [https://aws.amazon.com](https://aws.amazon.com/msk/what-is-kafka/)
* [https://www.tutorialspoint.com/apache_kafka/apache_kafka_introduction.htm](https://www.tutorialspoint.com/apache_kafka/apache_kafka_introduction.htm)
* [https://rclayton.silvrback.com/thoughts-on-node-rdkafka-development](https://rclayton.silvrback.com/thoughts-on-node-rdkafka-development)
* [https://kafka.js.org/docs/getting-started](https://kafka.js.org/docs/getting-started)