[
https://issues.apache.org/jira/browse/FLINK-38447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lwn updated FLINK-38447:
------------------------
Labels: pull_request_available (was: pull-request-available)
> Add table sink support for Elasticsearch 8 connector
> ----------------------------------------------------
>
> Key: FLINK-38447
> URL: https://issues.apache.org/jira/browse/FLINK-38447
> Project: Flink
> Issue Type: Improvement
> Components: Connectors / ElasticSearch
> Reporter: lwn
> Priority: Major
> Labels: pull_request_available
>
> Currently, the Elasticsearch 8 connector lacks a Table API sink
> implementation. So we should add one to complete the connector.
> The Elasticsearch 8 connector is built on the new Async Sink API and does not
> depend on the flink-connector-elasticsearch-base module. However, to maintain
> configuration consistency with existing Elasticsearch connectors (e.g., ES
> 6/7), {*}some utility classes and configuration definitions were directly
> reused from the base module{*}, but the configuration options are adapted to
> the capabilities of the Elasticsearch8AsyncSink.
> Key configuration changes include:
> - *Removed* options not supported by Elasticsearch8AsyncSink:
> - sink.bulk-flush.backoff.strategy
> - sink.bulk-flush.backoff.max-retries
> - sink.bulk-flush.backoff.delay
> - *Added* new options:
> - sink.bulk-flush.max-buffered-actions
> - ssl.certificate-fingerprint
> - *Retained and aligned* all other options with the Elasticsearch8AsyncSink
> configuration.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
