Re: unpacking a column from a JSON structured msg, using stream processing

2020-01-17 Thread George
ignore comment just saw the kSQL button. G On Fri, Jan 17, 2020 at 1:43 PM George wrote: > Hi Bruno > > From the description this looks exactly whats needed, will have to see how > to do this as I haven't touched Java in 20 yrs, someone did mention to me > this is also possible via kSQL and a

Re: unpacking a column from a JSON structured msg, using stream processing

2020-01-17 Thread George
Hi Bruno >From the description this looks exactly whats needed, will have to see how to do this as I haven't touched Java in 20 yrs, someone did mention to me this is also possible via kSQL and a user defined method. Any chance anyone has a example? G On Fri, Jan 17, 2020 at 10:21 AM Bruno Cado

Re: unpacking a column from a JSON structured msg, using stream processing

2020-01-17 Thread Bruno Cadonna
Hi George, Could the following tutorial help you? https://kafka-tutorials.confluent.io/transform-a-stream-of-events/kstreams.html Best, Bruno On Fri, Jan 17, 2020 at 7:48 AM George wrote: > > I have a topic with message as per: > > {'file_name' : filename, > 'line_number' : src_line_number,

unpacking a column from a JSON structured msg, using stream processing

2020-01-16 Thread George
I have a topic with message as per: {'file_name' : filename, 'line_number' : src_line_number, 'section' : vTag, 'line_data': line_data } I want to unpack line_data into multiple columns based on position. Can I do this via stream processing. the output will go onto a new topic/strea