@Shu This is the current Nifi flow ConsumeKafka -> UpdateAttribute -> ReplaceText -> PutSQL *In UpdateAttribute I am capturing kafka.topic, kafka.offset,kafka.partition, kafka.key and assigning to variables. topic=${kakfa.topic} partition=${kakfa.partition} offset=${kakfa.offset} key=${kakfa.key} *In ReplaceText processor I am replacing the flowfile content with insert statement. searchvalue = (?s)(^.*$) replacementvalue = Insert into test_schema.table1(topic, partition, offset, key, value) values ('${topic}','${partition}','${offset}','${key}','$1') But the nifi workflow is failing since the kafka value has single quotes in it as mentioned in initial post and sql server wont allow single quotes into the varchar column unless we double the single quote. I want to add one more ReplaceText processor and search the kafka value string and replace all the single quote occurrences with two single quotes. Please let me know what should be the search value and replacement value in the Replacetext processor. Please let me know if there is a better way to handle this scenario. Thanks
... View more
