parallel-consumer
parallel-consumer copied to clipboard
Ability use different consume and produce types for the key and value
I don't think it's possible to use ParallelStreamProcessor with Consumer and Producer that do not share the same KeyType and ValueType. Can this be considered in the future ?
Oh my! Yes! This is a breaking issue for the poll and produce use case. I will look into it with priority. Too much testing with just String types :)
Hi, i see that you remove the blocker label. Do you think the 1.0 version won't break after the implementation of the fix ?
i see that you remove the blocker label.
Whoops - mistake :) Still plan on changing this. Will be resuming work on PC this week :)
Btw, workaround is to use your own instance of a producer to send a result back to Kafka, of any type.
Or use a more abstract type for your registered serde like a byte serde or string serde and use the serdes manually.
Closing Issue