Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
languagejava
package org.apache.kafka.clients.producer;
public class DefaultPartitioner implements partitionerPartitioner {
}

 

Proposed Changes

  1. Add a new partitioner interface .
  2. Move existing partitioner code to DefaultPartitioner .
  3. Introduce new producer config called "partitioner.class" . By default it points to org.apache.kafka.clients.producer.DefaultPartitioner

...