lwn created FLINK-38447:
---------------------------
Summary: 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
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)
