Another partition problem

[exception13]

if use multiple process/threads with partitioning topic current realization StoreChangeLogger try write with specified partition without checking and repartition this topic.

Any ideas?

[ah-]

Hi, you mean it should ensure that the changelog topic has the same number of partitions as the input topic?

Agree that it should check, state management is still not finished. Would probably make most sense around the builder somewhere.

For creating more partitions we'd need confluentinc/librdkafka#986 first.