eunomia 数据总线->数据订阅客户端node.js版

Eunomia

options

• groupId kafka消息group
• kafkaHost kafka broker地址
• topics 一组topic，需要找戴建豪备案创建
• prefix topic前缀，通常只有测试环境配置test

方法

• addListener(key, callback: (rowData: json) => boolean | Promise) 添加监听，第一个参数为key;第二个参数为handler，入参为一条数据(包含变更类型event_type及每列变化前后的值)，出参为boolean值(或异步返回boolean)，为true则表示成功消费这条消息。
• connect() 连接consumer
• close() 重新连接consumer

Demo

const { Eunomia } = require('node-eunomia');
const eunomia = new Eunomia({
  groupId: 'testGroup',
  kafkaHost: '192.168.6.52:9192,192.168.6.53:9192',
  topics: ['forseti_prel_version']
});
eunomia.addListener('forseti_prel_version', rowData => {
  switch(rowData.event_type) {
    case 'INSERT':
      //...
      break;
    case 'UPDATE':
      //...
      break;
    case 'DELETE':
      //...
      break;
    default:
      //...
      break;
  }
  return true;
})
eunomia.connect();