You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "jinfeng (Jira)" <ji...@apache.org> on 2021/08/31 08:21:00 UTC

[jira] [Created] (FLINK-24072) Add support for setting default headers in elasticsearch connector

jinfeng created FLINK-24072:
-------------------------------

             Summary: Add support for setting default headers in elasticsearch connector
                 Key: FLINK-24072
                 URL: https://issues.apache.org/jira/browse/FLINK-24072
             Project: Flink
          Issue Type: Improvement
          Components: Connectors / ElasticSearch
            Reporter: jinfeng


If we add support for setting default headers , we can add some head options in sql options. 

The ddl would be like this. 
{code:sql}
// Some comments here
create table es-sink (
  a varchar,
  b varchar
) with (
  'connector' = 'elasticsearch-7',
  'connection.default-headers' = 'Authorization:xxxxxxx'
);
{code}




--
This message was sent by Atlassian Jira
(v8.3.4#803005)