kafka 批量回写mysql_kafka往mysql写数据操作笔记

第三讲代码

导入jar(df_connect_finance-0.1-jar-with-dependencies.jar)包到 /opt/lib/ 下

--------------------------------------------------------->>>>

POST http://localhost:8083/connectors/

body:

--------------------

{

"name": "finace_source_connector_01",

"config": {

"cuid": "finace_source_connector_01",

"connector.class": "com.datafibers.flink.stream.FinanceSourceConnector",

"tasks.max": "1",

"topic": "stock_source",

"portfolio": "Top 10 IT Service",

"interval": "5",

"spoof": "RAND",

"schema.registry.uri": "http://localhost:8081"

}

---------------------------

GET http://localhost:8002/subjects

GET http://localhost:8002/subjects/stock_source/versions

GET http://localhost:8002/schemas/ids/1

在第一个窗口输入：

kafka-avro-console-consumer --bootstrap-server localhost:9092 --topic stock_source

//然后就会不断有数据更新进来

在第二个窗口打开：mysql -u root -pmypassword

show databases；查看有没有simple_stream数据库

有的话use simple_stream；

没有的话create simple_stream；

进去看有没有stock_source

有的话drop掉

然后进入postman：

POST http://localhost:8083/connectors/

body:

---------------

{

"name": "jdbc-sink-mysql-01",

"config": {

"connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector",

"tasks.max": "1",

"topics": "stock_source",

"connection.url": "jdbc:mysql://localhost:3306/simple_stream",

"connection.user": "root",

"connection.password": "mypassword",

"auto.create": "true"

}

-----------------

回到mysql：

show tables；

select count(*) from simple_stream；//查看表内数据量

select * from simple_stream limit 0，10；//查看表内前十条；

kafka 批量回写mysql_kafka往mysql写数据操作笔记相关推荐

写一个清空Mysql数据库数据的脚本Shell
写一个清空Mysql数据库数据的脚本Shell 服务器安装部署mysql8.0.2,需要有 mysqldump 命令 #!/usr/bin/bash# mysql -e cmd 可以用shell操作m ...
CCS Uniflash烧写CC3200开发板的简易操作笔记
1 说明 CCS Uniflash是TI提供的一个烧写工具.其最新版不能支持烧写CC3200,因此,烧写CC3200使用的是CCS Uniflash 3.4.其下载地址为: http://www.ti ...
MySQL：数据操作
数据操作一.输入数据格式: mysql>INSERT INTO 数据表名 VALUES(输入数据); 例 mysql> INSERT INTO shujuleixing_xiaoshu ...
mysql四:数据操作
一介绍 MySQL数据操作: DML ======================================================== 在MySQL管理软件中,可以通过SQL语句中的 ...
MySQL 之数据操作
目录一介绍二增 INSERT 三删 DELETE 四改 UPDATE 五查 SELECT 5.1单表查询: https://blog.csdn.net/qq_35883464/ar ...
mysql 修改数据 where_MySQL笔记之修改数据的解决方法
数据库通过插入.更新和删除等方式来该表表中的记录,其中 insert语句实现插入数据 update语句实现更新数据 delete语句实现删除数据参考表插入数据不指定字段名插入不指定字段名插入 my ...
批处理操作mysql_用批处理对MySQL进行数据操作
批处理是一种非交互式运行mysql程序的方法,如同您在mysql中使用的命令一样,你仍然将使用这些命令. 为了实现批处理,您重定向一个文件到mysql程序中,首先我们需要一个文本文件,这个文本文件包含 ...
MySQL数据库肖睿版_正版 MySQL数据库应用技术及实战肖睿MySQL数据库数据操作数据恢复备份MySQL数据库优化My...
基本信息书名:MySQL数据库应用技术及实战定价:32.00元作者:肖睿程宁田崇峰出版社:人民邮电出版社出版日期:2018-01-01 ISBN:9787#115474223 字数: 页码: ...
MySQL查询数据操作（DQL）
查询记录单表查询SELECT语句完×××式: SELECT select_expr [ , select_expr ... ] [ FROM tbl_references [WHERE 条件] [G ...

kafka 批量回写mysql_kafka往mysql写数据操作笔记

kafka 批量回写mysql_kafka往mysql写数据操作笔记相关推荐

最新文章

热门文章

kafka 批量 回写mysql_kafka往mysql写数据操作笔记

kafka 批量 回写mysql_kafka往mysql写数据操作笔记相关推荐

最新文章

热门文章

kafka 批量回写mysql_kafka往mysql写数据操作笔记

kafka 批量回写mysql_kafka往mysql写数据操作笔记相关推荐