THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
Table of Contents |
---|
Status
Current state:"Under Discussion" Accepted
Discussion thread: here
JIRA: KAFKA-2091
Released: 0.8.3
Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).
...
Code Block | ||
---|---|---|
| ||
package org.apache.kafka.clients.producer;
public interface Partitioner extends Configurable {
/**
* This is called after partitioner is registered.
*/
public void init();
/**
* Configure partitioner class with given key,value pairs from partitioner.metadata config.
*/
@override
public void configure(Map<String, ?> configs);
/**
* Compute the partition for the given record.
*
* @param topic The topic name
* @param key The key to partition on (or null if no key)
* @param keyBytes The serialized key to partition on( or null if no key)
* @param value The value to partition on
* @param valueBytes The serialized value to partition on
* @param cluster The current cluster metadata
*/
public int partition(String topic, Object key, byte[] key, Object value, byte[] value, Cluster cluster);
/**
* This is called when partitioner is closed.
*/
public void close();
} |
...