[jira] [Created] (FLINK-16788) ElasticSearch Connector SQL DDL add optional config (eg: enable-auth/username/password)

["zhisheng (Jira)" <ji...@apache.org>]

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)