Jeff P
Jeff P
You should be able to deserialize the value using the following command : stream_read_kafka(sc,options = read_options)%>% mutate(value=as.character(value)) You can also change the deserializer in the read options, say if you...
there is no such thing as a second solution, the solution depends solely on which serializer was used when inserting data into kafka topic. You then deserialize accordingly using mutate,...
what serializer did you use to insert data into your kafka topic ? do you then pipe into mutate(value=as.character(value)) ?
ok can you show the output of: stream_read_kafka(sc,options = read_options, subscribe="mytopic") then the output of : mutate(value=as.character(value))
A simple example is a median-- there is no support for it in postgres without window function of that i am aware of. One might want to implement more complex...
Happy to see how you are doing this with today's capabilities. That being said, I am thinking ahead and at some point we ll end up with a lot of...
since i started using the java sdk, about a week ago