canal1.1.7集成rabbitmq集群配置
时间: 2023-07-05 14:33:15 浏览: 140
RabbitMQ 安装配置
首先,你需要在canal.properties文件中配置RabbitMQ的信息,例如:
```
## RABBITMQ
canal.mq.servers=rabbitmq1:5672,rabbitmq2:5672,rabbitmq3:5672
canal.mq.virtualHost=/
canal.mq.exchange=canal.exchange
canal.mq.username=guest
canal.mq.password=guest
```
其中,canal.mq.servers为RabbitMQ集群节点的地址和端口,多个节点使用逗号分隔;canal.mq.virtualHost为RabbitMQ的虚拟主机,默认为"/";canal.mq.exchange为RabbitMQ的交换机名称;canal.mq.username和canal.mq.password为连接RabbitMQ的用户名和密码。
然后,在canal.properties文件中启用RabbitMQ Canal Client插件:
```
## MQ Message
canal.mq.flatMessage=false
canal.mq.canalBatchSize=50
canal.mq.compressionType=none
canal.mq.plugin.name=rabbitmq
```
最后,在canal-server目录下的conf目录中创建rabbitmq目录,并在该目录中创建一个名为canal的队列:
```
rabbitmq/
└── rabbitmq.json
rabbitmq.json文件内容如下:
{
"autoDelete": false,
"durable": true,
"exchange": "canal.exchange",
"exclusive": false,
"queue": "canal",
"routingKey": "canal",
"type": "topic"
}
```
这样就完成了canal和RabbitMQ集群的集成配置。
阅读全文