[ https://issues.apache.org/jira/browse/FLINK-16788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17081809#comment-17081809 ]
Weike Dong commented on FLINK-16788: ------------------------------------ Hi [~zhisheng], this is a good feature proposal. Personally I think 'connector.enable-auth' option could become optional or removed, e.g. if users specify username and password, then definitely they want to enable authentication. > 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 > Priority: Major > 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)