如何使用 kafka 连接 JDBC sink 和 source 使用 python
How to use kafka connect with JDBC sink and source using python
我想从一个系统直播到另一个系统。
我正在使用 kafka-python 并且可以在本地直播。
计算出连接器将处理多个设备。有人可以建议我使用连接器在 python 中实现它的方法吗？
Kafka Connect 是一个 Java 框架，而不是 Python。
Kafka Connect 运行一个 REST API，您可以使用 urllib3 或 requests 与其交互，而不是 kafka-python
https://kafka.apache.org/documentation/#connect
创建连接器后，欢迎您使用 kafka-python 生成数据，例如，JDBC sink 将使用这些数据，或者例如，您可以使用 pandas 写入数据库，JDBC source（或 Debezium）将消耗
我想从一个系统直播到另一个系统。
我正在使用 kafka-python 并且可以在本地直播。
计算出连接器将处理多个设备。有人可以建议我使用连接器在 python 中实现它的方法吗？
Kafka Connect 是一个 Java 框架，而不是 Python。
Kafka Connect 运行一个 REST API，您可以使用 urllib3 或 requests 与其交互，而不是 kafka-python
https://kafka.apache.org/documentation/#connect
创建连接器后，欢迎您使用 kafka-python 生成数据，例如，JDBC sink 将使用这些数据，或者例如，您可以使用 pandas 写入数据库，JDBC source（或 Debezium）将消耗