使用apachekafka connect api和合流kafka connect api有什么区别?有人能分享代码连接到mysql数据库到kafka主题吗?
q3aa05251#
正如mike提到的,apachekafka连接和合流kafka连接之间没有核心区别。如果您不想编写任何代码,请使用kafka connect jdbc从mysql db读取数据并将其发送到kafka topic。要在笔记本电脑上快速演示,请遵循以下主要步骤:下载apache kafka经营一个Kafka经纪人从confluent站点下载kafka connect jdbc将lib/*.jar从kafka connect jdbc复制到kafka libs文件夹将mysql驱动程序复制到kafka libs文件夹创建jdbc源连接器配置文件使用jdbc源连接器配置$kafka\u home/bin/connect-standalone.sh../config/connect-standalone.properties../config/jdbc-connector-config.properties以独立模式运行kafka connect有用的链接https://www.confluent.io/blog/kafka-connect-deep-dive-jdbc-source-connector/httpshttp://docs.confluent.io/current/connect/kafka-connect-jdbc/index.html如果您想编写代码,那么就学习kafka producer api的用法。https://docs.confluent.io/current/clients/producer.htmlhttps://kafka.apache.org/documentation/#producerapi
1条答案
按热度按时间q3aa05251#
正如mike提到的,apachekafka连接和合流kafka连接之间没有核心区别。
如果您不想编写任何代码,请使用kafka connect jdbc从mysql db读取数据并将其发送到kafka topic。
要在笔记本电脑上快速演示,请遵循以下主要步骤:
下载apache kafka
经营一个Kafka经纪人
从confluent站点下载kafka connect jdbc
将lib/*.jar从kafka connect jdbc复制到kafka libs文件夹
将mysql驱动程序复制到kafka libs文件夹
创建jdbc源连接器配置文件
使用jdbc源连接器配置$kafka\u home/bin/connect-standalone.sh../config/connect-standalone.properties../config/jdbc-connector-config.properties以独立模式运行kafka connect
有用的链接
https://www.confluent.io/blog/kafka-connect-deep-dive-jdbc-source-connector/httpshttp://docs.confluent.io/current/connect/kafka-connect-jdbc/index.html
如果您想编写代码,那么就学习kafka producer api的用法。https://docs.confluent.io/current/clients/producer.htmlhttps://kafka.apache.org/documentation/#producerapi