zhisheng created FLINK-16788:
--------------------------------
Summary: ElasticSearch Connector SQL DDL add optional config (eg:
enable-auth/username/password)
Key: FLINK-16788
URL: https://issues.apache.org/jira/browse/FLINK-16788
Project: Flink
Issue Type: Improvement
Components: Connectors / ElasticSearch, Table SQL / API
Affects Versions: 1.10.0
Reporter: zhisheng
Fix For: 1.11.0
In a production environment, accessing elasticsearch usually requires
authentication, and requires a username and password to access it, but the
current version of SQL DDL does not support users to configure these parameters.
I have improve it in our company, and we use it as follows:
CREATE TABLE user_behavior_es (
user_idBIGINT,
item_id BIGINT
) WITH (
'connector.type'='elasticsearch',
'connector.version'='7',
'connector.hosts'='http://localhost:9200',
'connector.index'='user_behavior_es',
'connector.document-type'='user_behavior_es',
'connector.enable-auth'='true',
'connector.username'='zhisheng',
'connector.password'='123456',
'format.type'='json',
'update-mode'='append',
'connector.bulk-flush.max-actions'='10'
)
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
