kafka-connect-elasticsearch icon indicating copy to clipboard operation
kafka-connect-elasticsearch copied to clipboard

Support Elasticsearch aliases

Open goran-rumin opened this issue 3 years ago • 9 comments

Problem

The connector currently (version 11.1.3) doesn't support writing to Elasticsearch alias. Aliases are a convenient way to make the management of the underlying indices easy - like mapping updates, index rollover, etc. That, combined with the inability to use topic name transforms due to async commit makes alias usage very attractive.

Solution

Expanded index existence checks with alias existence check to prevent new index creation (and subsequent failing) when topic name corresponds to an alias.

Does this solution apply anywhere else?
  • [ ] yes
  • [ ] no
If yes, where?

Test Strategy

Testing done:
  • [x] Unit tests
  • [x] Integration tests
  • [x] System tests
  • [x] Manual tests

Release Plan

goran-rumin avatar Nov 08 '21 13:11 goran-rumin

The 3 build steps that are failing all have the same error message We have disabled builds for pull requests created by the open source communitydue to build system maintenance.We are working to finish it soon., so the build is not failing due to the code change. If this is expected, please ignore this comment, if not, I would kindly ask for your assistance with the issue.

goran-rumin avatar Dec 14 '21 11:12 goran-rumin

@goran-rumin Thanks for the contribution, I will request to consider this in the pipeline for Q1 planning.

kpatelatwork avatar Dec 16 '21 03:12 kpatelatwork

CLA assistant check
Thank you for your submission! We really appreciate it. Like many open source projects, we ask that you sign our Contributor License Agreement before we can accept your contribution.
You have signed the CLA already but the status is still pending? Let us recheck it.

CLAassistant avatar Apr 03 '22 12:04 CLAassistant

@kpatelatwork was this ever included in the planning?

Bhashit avatar May 08 '22 11:05 Bhashit

@Bhashit this was considered but did not make it to this quarter. CC: @rajat-agarwal

kpatelatwork avatar May 09 '22 16:05 kpatelatwork

@kpatelatwork this is also a feature we are looking for, are there any considerations to put this ticket on the roadmap so that it can be released soon (Q2/Q3)? Thank you.

Lowess avatar Aug 03 '22 07:08 Lowess

Thanks for the contribution @goran-rumin. I have added a couple of comments. Primarily my concern is the comment above.

snehashisp avatar Sep 01 '22 08:09 snehashisp

Thanks for reviewing @snehashisp, I added my responses to the comments. I kindly request your input on 2nd one, since it affects one of the features of the connector in case of alias usage.

goran-rumin avatar Jan 04 '23 10:01 goran-rumin

In my case i need to pre-generate the mapping of indices and auto rollover for it. I tried using data stream but this connector doesn't support exists mapping for data stream (follow issues 614) so I opted for using alias to push data into indices auto rollover. Unfortunately that option doesn't work either. Is there any way to help me?

quanvo17 avatar Jul 25 '23 15:07 quanvo17