Clojurians Log v2

@andrea.crotti see above... 🙂

@truemped I work for funding circle but I didn't work on this library (I do mostly clojurescript actually), I mentioned my colleagues that we have a question though

cool, thanks!

I though I read your name in the commit logs. Probably not...

Feel free to open github issues of course which at least don't disappear

I just did a couple of prs this week for the first time

I'm thinking the error is in my code somehow or I'm using it wrong.

Could be but could also be just something missing in the library since we never had that need so far

Just fyi he biggest contributors are in the pdt timezone

Hey @truemped. The value you're getting in the reducer might not be what you expect. I think while it's trying to serialize the reduction to your intermediate topic, it's throwing a serialization error because something that expects a String is getting a window instead.

ah, right

Actually looking at the test in here https://github.com/FundingCircle/jackdaw/blob/master/test/jackdaw/streams_test.clj#L685 ....do you have something similar in your code to this line that extracts the key out of the window?

(k/map (fn [[k v]] [(.key k) v]))

no, not really

how do the arguments to reduce look like? I thought it was just the value map

I'm also not using group-by but group-by-key

ah, I see. Up until (k/map (...)) the key is still a windowed key. My output-topic is non-windowed and should only receive the last value per time-window. So I need to transform the key to a non-windowed key... right?!

🙂

works like a charm! Thank you @cddr

Ah sorry I went awol. Seems like you figured it out though 🙂

yes, essentially like I said. Everything works fine up until I try to (k/to ...) a topic without windowed keys. For this I was missing the ('k/map ...) part.