A simple node-js client for MapR Streams using librdkafka C API

node v9.10.0
mapr-client v6.0.1

export DYLD_LIBRARY_PATH=$DYLD_LIBRARY_PATH:/opt/mapr/lib npm install npm run build ./bin/testRun ./bin/testRunTs 

• StreamsProducer.produce()
• StreamsConsumer.consume()

node index.js
Message [val] Delivered
Message [val] Delivered
Message [val] Delivered
Message [val] Delivered
Message [val] Delivered
Message [val] Delivered
Message [val] Delivered
Message [val] Delivered
Message [val] Delivered
Message [val] Delivered
********* CONSUMER START *********
Create new consumer configuration object
Set topic configurations
Create consumer Kafka handle
Create topic partition list for topic: /test:test
Subscribe consumer to the topic:
Destroy topic partition list:

Start message consumption:
1 Consumed: val
2 Consumed: val
3 Consumed: val
4 Consumed: val
5 Consumed: val
6 Consumed: val
7 Consumed: val
8 Consumed: val
9 Consumed: val
10 Consumed: val

Commit the offsets before closing the consumer

Close and destroy consumer handle