Versions Compared

Old Version 10

changes.mady.by.user Harsha

Saved on

compared with

New Version 11

changes.mady.by.user Harsha

Saved on

Key

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

...

  1. Add a new partitioner interface .
  2. Move existing partitioner code to DefaultPartitioner .
  3. If Users provide partition id than it will take precedence over partitioner.class .If partition id is null than only partitioner.class partition() method called to  compute partition for given Record.
  4. Introduce new producer config called "partitioner.class"   and "partitioner.metadata" . By default "partitioner.class" points to org.apache.kafka.clients.producer.DefaultPartitioner

...