我目前正在从事一项大型机技术，我们将数据存储在ibmdb2中。我们有了一个新的需求，即使用可扩展的流程将数据迁移到新的消息传递平台，包括新的数据库。为此，我们确定kafka是ksqldb或mongodb的合适解决方案。有人能告诉或指导我如何从kafka连接到ibmdb2来导入数据并将其放入ksqldb或mongodb吗？非常感谢您的帮助。
njthzxwz1#
要将数据从ibmdb2导入kafka，您需要使用任何连接器，比如用于db2的debezium连接器。有关接头的信息可以在下面找到。https://debezium.io/documentation/reference/connectors/db2.html连接器配置您也可以使用jdbc源连接器来实现相同的功能。以下链接有助于配置。https://www.confluent.io/blog/kafka-connect-deep-dive-jdbc-source-connector/一个简单的事件图从rdms流到kafka主题。在将数据放入kafka之后，我们需要将该数据传输到mongodb。我们需要使用mongo db连接器将数据从kafka传输到mongo db。https://www.mongodb.com/blog/post/getting-started-with-the-mongodb-connector-for-apache-kafka-and-mongodb-atlashttps://www.confluent.io/hub/mongodb/kafka-connect-mongodb
1条答案
按热度按时间njthzxwz1#
要将数据从ibmdb2导入kafka，您需要使用任何连接器，比如用于db2的debezium连接器。
有关接头的信息可以在下面找到。https://debezium.io/documentation/reference/connectors/db2.html
连接器配置
您也可以使用jdbc源连接器来实现相同的功能。以下链接有助于配置。
https://www.confluent.io/blog/kafka-connect-deep-dive-jdbc-source-connector/
一个简单的事件图从rdms流到kafka主题。
在将数据放入kafka之后，我们需要将该数据传输到mongodb。我们需要使用mongo db连接器将数据从kafka传输到mongo db。
https://www.mongodb.com/blog/post/getting-started-with-the-mongodb-connector-for-apache-kafka-and-mongodb-atlas
https://www.confluent.io/hub/mongodb/kafka-connect-mongodb