kafka-wrapper-library
v0.1.4
Published
A Kafka wrapper library for Kafka Consumers and Producers, made in Typescript.
Downloads
3
Readme
kafka-wrapper-library
A Kafka wrapper library for Kafka Consumers and Producers, made in Typescript.
Producer
Sending message
producer.sendMessages("another_new_topx", 0, "new_msg", new kafka.KeyedMessage('keyed', 'a keyed message'))
.then(value => {
console.log(value);
});
Creating a topic
producer_create_topic.createTopic("another_new_topx", true, null)
.then(value => {
console.log(value);
});
Consumer
Consuming a topic
.Consume(null, null);
High Level Producer
Sending a message
high_producer.sendMessages("another_new_topx", new kafka.KeyedMessage('keyed', 'a keyed message'))
Creating a topic
high_producer_create_topic.sendMessages("random_topic")
KafkaConsumerGroup
let new_comsumer_1 = consumerGroup.consumerInitiate('consumer1', 'another_new_topx');
new_comsumer_1.on('error', consumerGroup.onError);
new_comsumer_1.on('message', function () {
new_comsumer_1.close(true, function (error) {
console.log('consumer1 closed', error);
});
});
new_comsumer_2.on('error', consumerGroup.onError);
new_comsumer_2.on('message', consumerGroup.onMessage);
new_comsumer_2.on('connect', function () {
setTimeout(function () {
new_comsumer_2.close(true, function (error) {
console.log('consumer2 closed', error);
});
}, 25000);
});
let new_comsumer_3 = consumerGroup.consumerInitiate('consumer3', 'another_new_topx');
new_comsumer_3.on('error', consumerGroup.onError);
new_comsumer_3.on('message', consumerGroup.onMessage);
ProducerStream
Not functional yet!
producer_stream.sendMessages("another_new_topx", new kafka.KeyedMessage('keyed', 'a keyed message'))