admin 管理员组

文章数量: 887021

kafka连接mysql数据库,Kafka

Kafka-connect-jdbc-source连接mysql数据库实战

1、创建mysql数据库

为避免使用kafka连接数据库时意外修改或删除数据，建议单独创建一个只读用户(kafka)，仅用于读取数据；

使用root操作，进行如下操作

-- 创建数据库

create database test;

-- 创建只读用户

create user 'kafka'@'127.0.0.1' identified by '123456';

-- 赋予查询授权

grant select on test.* to 'kafka'@'127.0.0.1';

-- 刷新权限

flush privileges;

-- 创建测试表

CREATE TABLE `sys_config` (

`cfg_id` int(11) NOT NULL,

`cfg_name` varchar(20) DEFAULT NULL,

`cfg_notes` varchar(50) DEFAULT NULL,

`cfg_value` varchar(20) DEFAULT NULL,

`modified` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP,

PRIMARY KEY (`cfg_id`)

)

使用kafka登录mysql，验证是否可以正常访问数据库：

mysql -u kafka -p -h 127.0.0.1<

本文标签： kafka连接mysql数据库 Kafka

版权声明：本文标题：kafka连接mysql数据库,Kafka 内容由网友自发贡献，该文观点仅代表作者本人， 转载请联系作者并注明出处：http://www.freenas.com.cn/jishu/1687017996h55704.html， 本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，一经查实，本站将立刻删除。