We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
版本:1.1.8 使用TCP模式,客户端可以正常接收到数据库的变更记录 更换为RabbitMQ模式后,对应队列接收不到
rabbitmq.host = 127.0.0.1 rabbitmq.virtual.host = / rabbitmq.exchange =amq.direct rabbitmq.username = guest rabbitmq.password = guest rabbitmq.queue =canal.dbdev rabbitmq.routingKey =canal.dbdev rabbitmq.deliveryMode =
日志无任何错误,meta.log也能正常记录
The text was updated successfully, but these errors were encountered:
追踪源码解决了,万万没想到: canal.properties里面的rabbitmq配置只是用来连接rabbitmq和创建交换机和队列,真正发送的队列设置是在instance.properties的canal.mq.topic对应的routekey
Sorry, something went wrong.
No branches or pull requests
Question
版本:1.1.8
使用TCP模式,客户端可以正常接收到数据库的变更记录
更换为RabbitMQ模式后,对应队列接收不到
队列配置
rabbitmq.host = 127.0.0.1
rabbitmq.virtual.host = /
rabbitmq.exchange =amq.direct
rabbitmq.username = guest
rabbitmq.password = guest
rabbitmq.queue =canal.dbdev
rabbitmq.routingKey =canal.dbdev
rabbitmq.deliveryMode =
日志无任何错误,meta.log也能正常记录
The text was updated successfully, but these errors were encountered: