kafka-streams: Using custom partitioner with higher level DSL constructs?

(lemme know if this belongs on the users email list, I'm not sure where API questions fall) Hi, I'm Ben Osheroff, I wrote Maxwell (http://github.com/zendesk/maxwell) and have been prototyping an engine to do arbitrary denormalizations of Maxwell's CDC events based on the kafka-

kafka-streams: Using custom partitioner with higher level DSL constructs?

(lemme know if this belongs on the users email list, I'm not sure where API questions fall) Hi, I'm Ben Osheroff, I wrote Maxwell (http://github.com/zendesk/maxwell) and have been prototyping an engine to do arbitrary denormalizations of Maxwell's CDC events based on the kafka-