test-clt-node-dev-kit

1. kafka

using kafkajs lib.

1) Consumer

• connect()
• subscribe(topicOption)
• recvMessage(callback, notifier)
• recvMessages(callbackForArray, maxBucketSize, notifier)
• recvEntry(callback, notifier)
• recvEntries(callbackForArray, maxBucketSize, notifier)
• disconnect()

2) Producer

• connect()
• send(topic, message, key)
• sendBatch(topic, messages, keys)
• disconnect()

2. redis

• putHash(key, tx)
• getHash(key)
• getFields(key, ...fields)
• getList(key)
• push(key, value)
• shift(key, value)
• put(key, value)
• get(key)
• del(key)
• sadd(key, value)
• srem(key, value)
• sismember(key, value)
• exists(key)
• close()

3. mariadb

• query(sql, data)
• batch(sql, batchData)
• close()

4. queryprocessor

• transform(httpQuery)
  • transform from http query string to sql query string