Kai Chen created FLINK-17116:
--------------------------------
Summary: support UsernamePasswordCredentials for elasticsearch
sink via SQL DDL
Key: FLINK-17116
URL: https://issues.apache.org/jira/browse/FLINK-17116
Project: Flink
Issue Type: New Feature
Components: Connectors / ElasticSearch, Table SQL / Ecosystem
Reporter: Kai Chen
Fix For: 1.11.0
support UsernamePasswordCredentials for elasticsearch sink via SQL DDL.
For example:
{code:java}
CREATE TABLE es_sink (
...
) WITH (
'connector.type' = 'elasticsearch',
'connector.version' = '6',
'connector.hosts' = 'host:port',
'connector.index' = 'index_name',
'connector.document-type' = 'type_name',
'connector.credential.username' = 'es_username',
'connector.credential.password' = 'es_password'
...
);
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
