Yanquan Lv created FLINK-37200:
----------------------------------
Summary: Add e2e test for ElasticSearch Sink.
Key: FLINK-37200
URL: https://issues.apache.org/jira/browse/FLINK-37200
Project: Flink
Issue Type: Improvement
Components: Flink CDC
Affects Versions: cdc-3.3.0
Reporter: Yanquan Lv
Fix For: cdc-3.4.0
Add e2e test for ElasticSearch Sink.
For example:
```
source:
type: mysql
name: MySQL Source
hostname: 127.0.0.1
port: 3306
username: admin
password: pass
tables: adb.\.*, bdb.user_table_[0-9]+, [app|web].order_\.*
server-id: 5401-5404
sink:
type: elasticsearch
name: Elasticsearch Sink
hosts: http://127.0.0.1:9092,http://127.0.0.1:9093
route:
- source-table: adb.\.*
sink-table: default_index
description: sync adb.\.* table to default_index
pipeline:
name: MySQL to Elasticsearch Pipeline
parallelism: 2
```
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
