I have used the “io.confluent.connect.transforms.ExtractTopic$Value” transforms in my elastic sink connector. but it was failed. it throws the following errors. It was working previous version of the elastic sink connector.
The error is,
The connector doesn't support topic mutating SMTs
Here my question is,
Please help me to resolve this issues.
The reason it’s not supported is because the index name will be decided before the transform, I believe, so an index will not get automatically created for the right topic value.
The workaround is to create your ES indicies/mappings ahead of time.
Even if you used a custom transform, the topic name cannot be mutated, as the error says. I’m not sure where this logic is validated, though.
Hi,
But this feature was working in the elastic sink connector’s older version(11.x).
Why this feature was revoked in the new version.
Thanks,
Balasubramanian N.
If you want to mutate the topic, use synchronous flushes
This topic was automatically closed 30 days after the last reply. New replies are no longer allowed.