![]() ![]() ![]() To prevent that explosion, you can add a transform that drops records that have null values. ![]() The ValueToKey transform requires a non-null record value, and will blow up if it sees one. One other important detail: when a document is deleted in Couchbase, the source connector publishes a record with a null value. Transforms=deserializeJson,someOtherTransform Love, respect, and forgiveness are the fundamental values that every family. To do this, include the DeserializeJson transform as the first in the chain and set nverter to JsonConverter instead of ByteArra圜onverter like so: =. The Metamorphosis By Franz Kafka: Transformation Of Each Member Of The Family. If you wish to use these handlers together with transforms that modify document content, the record value must be converted from a byte array to a compatible format. There’s a section buried in the connector documentation aboutĪs a performance optimization, RawJsonSourceHandler and its cousin RawJsonWithMetadataSourceHandler create Kafka Connect records whose values are byte arrays. But let’s assume that’s not what you want, and address the SMT issue. One way forward might be to make the Couchbase document ID the same as the user ID. (If you’re seeing some other behavior, please let me know so we can fix the bug). ![]() The source connector uses the Couchbase document ID as the Kafka record key. UUID message key the couchbase source connector generates ![]()
0 Comments
Leave a Reply. |