THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
There is one new method exposed on the partitioner interface.
Code Block | ||
---|---|---|
| ||
/** * Executes right before a new batch will be created. For example, if a sticky partitioner is used, * this method can change the chosen sticky partition for the new batch. * @param topic The topic name * @param cluster The current cluster metadata * @param prevPartition The partition of the batch that was just completed */ default public void batchCompleted(String topic, Cluster cluster, int prevPartition) { } |
The method batchCompleted will execute code right before a new batch is created. The sticky partitioner will define this method to update the sticky partition. This includes changing the sticky partition even when there will be a new batch on a keyed value. Test results show that this change will not significantly affect latency in the keyed value case.
...