有一个将值写入数据库的遗留服务。我需要将值转换为事件，然后发送给Kafka。我要做一个服务，每隔一个固定的延迟检查一次新记录并发送它们，同时将提交的记录id写入技术表，但是也许还有其他的方法，最佳实践或模式。
tpgth1q71#
您可能需要研究debezium，它在关系型和nosql数据存储上实现变更数据捕获，并将数据流到kafka中。https://github.com/debezium/debeziumhttps://debezium.io/documentation
1条答案
按热度按时间tpgth1q71#
您可能需要研究debezium，它在关系型和nosql数据存储上实现变更数据捕获，并将数据流到kafka中。
https://github.com/debezium/debezium
https://debezium.io/documentation