Confluent Kafka SMT Filter Problem

Kafka Connect Self-Managed Connectors
4

Looking back on what I’ve written, I think I was talking nonsense :confused:

You had the order correct to start with, i.e.

"transforms": "ignoreDeletes,deserializeJson,ignoreNonSuppliers",

Reading through the Couchbase connector docs, could you try this, using the com.couchbase.connect.kafka.handler.source.DefaultSchemaSourceHandler:

"couchbase.source.handler": "com.couchbase.connect.kafka.handler.source.DefaultSchemaSourceHandler",
"value.converter": "io.confluent.connect.avro.AvroConverter",
"value.converter.schema.registry.url":"http://schema-registry:8081"

This assumes you have a Schema Registry running on that URL and port.

I’m not familiar with this connector, and am somewhat grasping at straws. You may want to try posting over at the Couchbase forum too.