Sink should handle records without _id field about cloudant-kafka-connector

[drsm79]

Cloudant (and Couch) will generate an _id for you, a GUID, if one isn't provided. Is that sufficient, or does it need to be deterministic from the records data?

[dbtucker]

A completely unique ID is sufficient. The advantage of generating one is that the ID could give you some ordering details from the Kafka framework if that was important downstream ... which is why some other connectors take the approach of concatenating topic-name, partition, and offset (which for a given Kafka Cluster will be unique id for all messages that flow through the system).

[danielLinke]

The _id record handling can set in the configuration file connect-cloudant-sink.properties via the optional attribute guid.schema. The attribute can have following values:

guid.schema=kafka (default)
generate a new unique _id with the following schema:
<topic_name>_<partition>_<offset>_<sourceCloudantObjectId>

guid.schema=cloudant
using existing object id from the Cloudant source database

guid.schema=others
Cloudant generate a new _id