conduktor / kafka-stack-docker-compose

docker compose files to create a fully working kafka stack
Apache License 2.0
3.24k stars 1.25k forks source link

WARN Ignoring version conflicts for items: [Key{deposit_transactions/87114812}] (io.confluent.connect.elasticsearch.jest.JestElasticsearchClient) #89

Closed izzie88 closed 2 years ago

izzie88 commented 3 years ago

Hello,

I have set this up with multiple brokers and mutliple connect for reduncancy however when i use the elastic sink connector i get a lot of WARN Ignoring version conflicts for items: errors.

Please can you advise on how i can eradicate the errors.

Kind regards.

see sample error logs below:

kafka-connect1_1 | [2021-04-29 07:08:56,556] WARN Ignoring version conflicts for items: [Key{moniepoint.monnify_agency_banking.deposit_transactions/deposit_transactions/87115999}, Key{moniepoint.monnify_agency_banking.deposit_transactions/deposit_transactions/87115980}] (io.confluent.connect.elasticsearch.jest.JestElasticsearchClient) kafka-connect1_1 | [2021-04-29 07:08:57,056] WARN Ignoring version conflicts for items: [Key{moniepoint.monnify_agency_banking.deposit_transactions/deposit_transactions/87115986}] (io.confluent.connect.elasticsearch.jest.JestElasticsearchClient) kafka-connect1_1 | [2021-04-29 07:08:58,056] WARN Ignoring version conflicts for items: [Key{moniepoint.monnify_agency_banking.deposit_transactions/deposit_transactions/87116014}] (io.confluent.connect.elasticsearch.jest.JestElasticsearchClient) kafka-connect1_1 | [2021-04-29 07:09:01,052] WARN Ignoring version conflicts for items: [Key{moniepoint.monnify_agency_banking.deposit_transactions/deposit_transactions/87116014}] (io.confluent.connect.elasticsearch.jest.JestElasticsearchClient) kafka-connect1_1 | [2021-04-29 07:09:03,553] WARN Ignoring version conflicts for items: [Key{moniepoint.monnify_agency_banking.deposit_transactions/deposit_transactions/87116045}] (io.confluent.connect.elasticsearch.jest.JestElasticsearchClient)

simplesteph commented 2 years ago

Sorry, this is something to ask on the elasticsearch connector repo