Skip to content
New issue

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

无法在rabbitmq生产消息 #5411

Open
arcytan opened this issue Mar 21, 2025 · 1 comment
Open

无法在rabbitmq生产消息 #5411

arcytan opened this issue Mar 21, 2025 · 1 comment

Comments

@arcytan
Copy link

arcytan commented Mar 21, 2025

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也能正常记录

@arcytan
Copy link
Author

arcytan commented Mar 22, 2025

追踪源码解决了,万万没想到:
canal.properties里面的rabbitmq配置只是用来连接rabbitmq和创建交换机和队列,真正发送的队列设置是在instance.properties的canal.mq.topic对应的routekey

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant