Unlock a world of possibilities! Login now and discover the exclusive benefits awaiting you.
Thanks @vapukov for the reply.
The problem was not in the code but in the column which was receiving this value in the downstream tkafkaoutput where I had used 'Byte' instead of byte[]. I was able to resolve it then. Thanks anyways
output_row.SerializedValue = new StringBuilder()
is String variable,
but you try to assign for string variable byte[] value
remove .getBytes from your code and add one more column for test
output_row.SerializedValueByteswith type byte[]
at the end of your code add:
output_row.SerializedValueBytes = output_row.SerializedValue.getBytes();
Thanks @vapukov for the reply.
The problem was not in the code but in the column which was receiving this value in the downstream tkafkaoutput where I had used 'Byte' instead of byte[]. I was able to resolve it then. Thanks anyways