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) { } |
...