dmai-starter-kafka-client v0.2.1

DMAI-STARTER-KAFKA-CLIENT

Wrapper for kafka-node. Both producer and consumer.

Usage

Producer

const { KafkaProducerClient } = require('dmai-starter-kafka-client');

const config = {
    kafkaHost: 'node6:9092,node7:9092,node8:9092'
};
const producer = new KafkaProducerClient(config);

producer.send('TEST-TOPIC', {msg: 'test'})

Consumer

const { KafkaConsumerClient } = require('dmai-starter-kafka-client');

const config = {
    kafkaHost: 'node6:9092,node7:9092,node8:9092'
};
const topicConf = [{
    name: 'TEST-TOPIC',
    gid: 'kafka_consumer_client_test',
}]

const testClients = topicConf.map((k) => new KafkaConsumerClient(config, k.name, k.gid));

testClients.forEach(function (client) {
    client.registeListener(function (msg) {
        console.log('receive msg: ', msg);
    })
});

Develop

set registry

npm config set registry http://192.168.3.13:8081/repository/npm/

login

login with your LDAP account:

npm login --registry=http://192.168.3.13:8081/repository/npm_hosted/

publish

npm publish --registry=http://192.168.3.13:8081/repository/npm_hosted/