Elastic Sink Connector not working new version

user_15972498 0
Viewed 256

I have used the "io.confluent.connect.elasticsearch.ElasticsearchSinkConnector" version 13.0.0.

I am doing the SMT for this connector. but I got the below error.

Found a topic name 'es.contact3.model' that doesn't match the assigned partitions. The connector doesn't support topic mutating SMTs

I got the error even though I set the "flush.syncronously": "true".

My config is as follows,

{
    "type.name": "_doc",
    "connector.class": "io.confluent.connect.elasticsearch.ElasticsearchSinkConnector",
    "topics": "es.contact.model",
    "tasks.max": "1",
    "transforms": "Dealership",
    "key.ignore": "true",
    "input.data.format": "AVRO",
    "transforms.Dealership.type": "io.confluent.connect.transforms.ExtractTopic$Value",
    "transforms.Dealership.field": "indexTopicName",
    "schema.ignore": "true",
    "name": "ContactElasticSinkConnector",
    "flush.syncronously": "true",
    "connection.url": "http://192.168.1.7:19200",
    "transforms.Dealership.skip.missing.or.null": "true"
}
confluent-platform apache-kafka-connect elasticsearch apache-kafka
1 Answers

I faced this same issue and decided to try what you did within your question. There is a typo within:

"flush.syncronously": "true"

It should be:

"flush.synchronously": "true"

Simply making this correction worked for me.

user_147174930
Related