Skip to content

Feature: Version Ignore

Latest
Compare
Choose a tag to compare
@yzia2000 yzia2000 released this 16 Apr 09:58

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.