This module wraps KafkaJS commands
npm install --save @studiowebux/pubsub
TL;DR; Same as kafkajs, they are split using a different approach but the rest is the same.
const config = {
// Documentation: https://kafka.js.org/docs/configuration
client: {
clientId: 'my-app',
brokers: ['localhost:9092'],
logLevel: logLevel.DEBUG,
logCreator,
},
// Documentation: https://kafka.js.org/docs/producing#options
producer: { connect: {} },
// Documentation: https://kafka.js.org/docs/consuming#options
consumer: { connect: {}, subscribe: { fromBeginning: false } },
};
TBD
npm run doc
The
/examples
directory has one example, use thestart.sh
script
Pull requests are welcome. For major changes, please open an issue first to discuss what you would like to change.
SEE LICENSE IN license.txt