q-meet/mysqltoelasticsearch

mysql数据导入ElasticSearch

从Mysql到Elasticsearch

流程

MySQL -> Binlog -> kafka -> consumer -> elasticsearchEs —> query -> keyword -> 搜索结果

1. 导入sql database.sql

2. 配置文件 配置 数据库 kafka es 相关配置

以下示列配置

mysql:
  host: 127.0.0.1
  port: 3306
  user: root
  password: root
  database: test
es:
  host: http://127.0.0.1
  port: 9200
  user:
  password:
kafka:
  host: localhost
  port: 9092
  topic: kafka_log

3. binlog To kafka

go run main.go -s=binlog

4. kafka To elasticsearchEs

go run main.go -s=es

5. http 展示

go run main.go -s=http

访问url: http://127.0.0.1:8088/CategorySearch

筛选 做了nicename的精准匹配 http://127.0.0.1:8088/CategorySearch?name=news