Skip to content

Releases: glints-dev/kafka-connect-elasticsearch

Feature: Version Ignore

16 Apr 09:58
Compare
Choose a tag to compare

Creates a connect configuration - version.ignore

If key.ignore is set to false, then the kafka record offset will be used as Elasticsearch EXTERNAL version. Duplicate records and out-of-order records are ignored while indexing.

However, this prevents the kafka topic from being recreated as the offsets will change. version.ignore allows control over request version. When set to true, Elasticsearch INTERNAL version is used and kafka record offset are ignored for indexing. When set to false, EXTERNAL version is used.