Versions Compared

Key

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

...

Code Block
languagejava
    public static final String INTERNAL_REPLICA_PLACER_CLASS_NAME = "replica.placer.class.name";
    public static final String INTERNAL_REPLICA_PLACER_CLASS_NAME_DEFAULT = StripedReplicaPlacer.class.getName();
    public static final String INTERNAL_REPLICA_PLACER_CLASS_NAME_DOC = "The fully qualified class name of the ReplicaPlacer implementation. This class is used by the broker to determine the placement of replicas when topics or partitions are created.";

...

Add new test for new internal config internal.replica.placer.class.name

Rejected Alternatives

KIP-660: Pluggable ReplicaPlacer, but the proposal was ultimately rejected due to the following concerns:

  • Implementing an intelligent placement strategy may require access to the full cluster state, which could be prohibitively expensive in large deployments.

  • Such strategies could become overly complex and harder to maintain.

  • Slow or inefficient placement logic could block the controller thread, negatively impacting Kafka's overall stability.