THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||
---|---|---|
| ||
package org.apache.kafka.clients.producer; public class DefaultPartitioner implements partitionerPartitioner { } |
Proposed Changes
- Add a new partitioner interface .
- Move existing partitioner code to DefaultPartitioner .
- Introduce new producer config called "partitioner.class" . By default it points to org.apache.kafka.clients.producer.DefaultPartitioner
...