parallel-consumer icon indicating copy to clipboard operation
parallel-consumer copied to clipboard

Ability use different consume and produce types for the key and value

Open BDeus opened this issue 2 years ago • 5 comments

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 ?

BDeus avatar Oct 19 '21 15:10 BDeus

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 :)

astubbs avatar Oct 19 '21 16:10 astubbs

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 ?

BDeus avatar Jan 31 '22 10:01 BDeus

i see that you remove the blocker label.

Whoops - mistake :) Still plan on changing this. Will be resuming work on PC this week :)

astubbs avatar Feb 01 '22 14:02 astubbs

Btw, workaround is to use your own instance of a producer to send a result back to Kafka, of any type.

astubbs avatar Apr 12 '22 09:04 astubbs

Or use a more abstract type for your registered serde like a byte serde or string serde and use the serdes manually.

astubbs avatar Apr 12 '22 09:04 astubbs

Closing Issue

johnbyrnejb avatar Jul 07 '23 14:07 johnbyrnejb