I’m getting task is being killed error while pushing data from confluent topic to scylladb using scylla sink connector.
record.valueSchema() must contain all of the fields in record.keySchema(). record.keySchema() is used by the connector to determine the key for the table. record.valueSchema() is missing field ‘product_id’. record.valueSchema() is used by the connector to persist data to the table in ScyllaDb. Here are the available fields for record.valueSchema(source, before, after, op, ts_ms, transaction) and record.keySchema(product_id).