Re: ClassCastException in KStreams job for SessionWindow aggregation

2018-05-02 Thread Conrad Crampton
Thanks Damian for taking the time to point out my stupidity - that was it :-) Case of Occams Razor!! Thanks again On Wed, 2 May 2018 at 16:56 Conrad Crampton wrote: > Looks like I may be victim of that copy and paste gremlin!! > Without checking I think you might be onto something - I&#x

Re: ClassCastException in KStreams job for SessionWindow aggregation

2018-05-02 Thread Conrad Crampton
); > > final Deserializer httpSessionDeserializer = new > JsonPOJODeserializer<>(); > serdeProps.put("JsonPOJOClass", Http.class); > httpSessionDeserializer.configure(serdeProps, false); > > Shouldn't the class be HttpSession.class ?

ClassCastException in KStreams job for SessionWindow aggregation

2018-05-02 Thread Conrad Crampton
I'm trying to window over http logs and create an HttpSession i.e. a list of http requests (and some other properties). However when in my aggregate Merger part (I think) I'm getting a classcastexception I think in when my sessions are being merged and cannot for the life of me work out why. The ex