Apache Kafka is een gedistribueerd streamingplatform dat wordt gebruikt voor het bouwen van real-time datastromen en toepassingen. Er zijn een paar methoden om Apache Kafka met Node.js te gebruiken, maar hier is een eenvoudige implementatie met behulp van de `kafka-node` bibliotheek.
1. Installeer de Kafka-Node bibliotheek: Je kunt dit doen door de volgende opdracht te gebruiken:
\`\`\`bash npm install kafka-node \`\`\`1. Maak een verbinding met een Kafka broker: Hier is een eenvoudig voorbeeld van hoe je verbinding maakt met een Kafka broker met behulp van de `kafka-node` bibliotheek.
\`\`\`javascript const kafka = require(‘kafka-node’); const client = new kafka.KafkaClient({kafkaHost: ‘localhost:9092’}); \`\`\` In dit voorbeeld is het Kafka broker adres `localhost:9092`. Vervang dit door het adres van je eigen Kafka broker.1. Produceer een bericht naar Kafka:
\`\`\`javascript const producer = new kafka.Producer(client); const payloads = [{ topic: ‘test’, messages: ‘Hello Kafka’ }]; producer.on(‘ready’, function () { producer.send(payloads, function(err, data) { console.log(data); }); }); \`\`\` In dit voorbeeld wordt een bericht `Hello Kafka` geproduceerd naar de `test` onderwerp op Kafka.1. Consumeer een bericht van Kafka:
\`\`\`javascript var consumer = new kafka.Consumer( client, [{topic: ‘test’, partition: 0}], {autoCommit: false} ); consumer.on(‘message’, function(message) { console.log(message); }); \`\`\` In dit voorbeeld wordt een bericht geconsumeerd van de `test` onderwerp op Kafka.Vergeet niet dat je een Kafka broker draaiend moet hebben om deze code uit te voeren.
Let op: Deze voorbeeldcode is eenvoudig gemaakt om de integratie van Kafka met node.js te illustreren. In een productie-omgeving moet je de juiste foutafhandeling en schone ontkoppeling van producenten en consumenten implementeren.
