如何使用Kafka与JDBC接收器连接，并使用Python进行源连接 [英] How to use kafka connect with JDBC sink and source using python

问题描述

我要从一个系统实时传输到另一个系统。

我正在使用kafka-python，可以在本地直播。

计算出连接器将处理多个设备。有没有人能给我提个建议，让我用连接符来实现它？

推荐答案

Kafka Connect是Java框架，不是Python.

Kafka Connect运行REST API，您可以使用urllib3或requests与其交互，而不是kafka-python

https://kafka.apache.org/documentation/#connect

创建连接器后，欢迎使用kafka-python生成数据，例如JDBC接收器将消耗的数据，或者您可以使用pandas例如写入数据库，JDBC源(或Debezium)将消耗

这篇关于如何使用Kafka与JDBC接收器连接，并使用Python进行源连接的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！