kafka-connect-elasticsearch
kafka-connect-elasticsearch copied to clipboard
Support for ES ingest pipelines
Would it be possible to support ingest pipelines, in case we want to add additional logic before indexing the document?
Currently, I have to consume the messages from topic A and write to a new topic B that will be sent to ES. I'd rather use ES pipelines for this.