deepstream.io-msg-kafka

deepstream message connector for Apache Kafka

This connector uses the npm kafka-node package. Please have a look there for detailed config options.

Basic Setup

const Deepstream = require('deepstream.io');
const KafkaMessageConnector = require('deepstream.io-msg-kafka');  // Currently there is no npm package. Coming soon!
const server = new Deepstream();
 
server.set('messageConnector', new KafkaMessageConnector({
  connectionString: 'localhost:2181'
}));
 
server.start();