Closed gurry closed 3 months ago
Please allow a custom partitioner to be set in Streamiz as we can do in Confluent.Kafka's ProducerBuilder?
My requirement is that when my topology emits events it needs to use a partition key that is different from the event key
@gurry
What do you need as the inputs of the partitioner ? topic, key, value is enough ?
Thanks @LGouellec for picking this up.
Yes, absolutely. Topic, key and value would be perfect.
Please allow a custom partitioner to be set in Streamiz as we can do in Confluent.Kafka's ProducerBuilder?
My requirement is that when my topology emits events it needs to use a partition key that is different from the event key