Pulsar适配GaussDB开源验证任务心得
根据计划书了解到需要使用Pulsar来作为数据同步工具,向Gauss同步数据,并验证;总体来说,部署并不复杂,环境安装JDk即可;需要注意各版本组件的兼容的问题;参考:https://pulsar.apache.org/docs/4.0.x/
下面是一些相关步骤(以单机部署为例):
开发过程:
1、需要提前安装安装JDK8+版本,最好是JDK17
2、下载官方 Apache Pulsar 发行版:
wget https://archive.apache.org/dist/pulsar/pulsar-4.0.1/apache-pulsar-4.0.1-bin.tar.gz
3、下载后,解压 tar 文件:
tar xvfz apache-pulsar-4.0.1-bin.tar.gz
4、解压文件
cd apache-pulsar-4.0.1
5、启动
bin/pulsar standalone
看到类似信息,代表启动成功
6、另开一个窗口
创建一个主题
bin/pulsar-admin topics create persistent://public/default/my-topic
向主题内写数据
bin/pulsar-client produce my-topic --messages ‘Hello Pulsar!’
显示成功;
7、再开一个窗口
读取数据
bin/pulsar-client consume my-topic -s ‘my-subscription’ -p Earliest -n 0
代表服务已经通畅
接下来需要到java编辑内写代码
参考地址:https://gitcode.com/weixin_43198678/Pulsar/overview
总结:部署可以说是相当简单,但是使用时发现,由于框架过于新,可能需要调换GaussDB的一些连接器,需要比较新的版本否则可能导致CDC功能无法开始,或者无法监控的情况;详情请仔细观看官网文档,都有很详细的讲解。
- 点赞
- 收藏
- 关注作者
评论(0)