如何从数据库创建kafka事件?

How to create kafka event from database?

有一个遗留服务将值写入数据库。 我需要将值转换为事件,然后将其发送到 kafka。

我将提供一项服务,一旦固定延迟检查新记录并发送它们,还将提交的记录 ID 写入技术 table,但也许还有其他方法, 最佳实践或模式。

您可能想查看 Debezium,它在关系和 NoSql 数据存储上实现变更数据捕获并将数据流式传输到 Kafka。

https://github.com/debezium/debezium

https://debezium.io/documentation