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();