DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
| Table of Contents |
|---|
Status
Current state: Under DiscussionAccepted
Discussion thread: here
JIRA: here [Change the link from KAFKA-1 to your own ticket]
| Jira | ||||||
|---|---|---|---|---|---|---|
|
Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).
...
If the automatic partitioning is needed (i.e. no record partition or key is specified; or partitioner.ignore.keys is set to true):
- If the client rack is specified and there are partition leaders in the same rack, select the next partition from those “nearby” partitions. The current algorithm is followed in the other aspects, including load balancing.
- Select the next partition from all partitions following the current algorithm in the following cases:
- if the client rack is not specified;
- if there are no partitions with leaders in the same rack as the client;
- if all the “nearby” partitions are unavailable.
- if
partitioner.rack.awareis false.
The new behavior will be controlled by configuration.
...
| Key Name | Description | Valid Values | Default Value |
|---|---|---|---|
| Controls whether the default partitioner is rack-aware. This has no effect when a custom partitioner is used. | true, false | false |
(already exists for consumers) | Specifies the rack of the client | strings |
...