oracle 导入 kafka 用什么etl

oracle 导入 kafka 用什么etl

可以用PyMySQL代替。安装方法：pip install PyMySQL
然后在需要的项目中，把 __init__.py中添加两行：
import pymysql
pymysql.install_as_MySQLdb()
就可以用 import MySQLdb了。其他的方法与MySQLdb一样。

kafka是由linkedin设计的一个高吞吐量、分布式、基于发布订阅模式的消息系统，使用scala编写，它以可水平扩展、可靠性、异步通信和高吞吐率等特性而被广泛使用。目前越来越多的开源分布式处理系统都支持与kafka集成，其中spark streaming作为后端流引擎配合kafka作为前端消息系统正成为当前流处理系统的主流架构之一。 然而，当下越来越多的安全漏洞、数据泄露等问题的爆发，安全正成为系统选型不得不考虑的问题，kafka由于其安全机制的匮乏，也导致其在数据敏感行业的部署存在严重的安全隐患。本文将围绕kafka，先介绍其整体架构和关键概念，再深入分析其架构之中存在的安全问题，最后分享下transwarp在kafka安全性上所做的工作及其使用方法。