THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
org.apache.kafka.clients.producer.Partitioner
Code Block | ||||
---|---|---|---|---|
| ||||
@Deprecated default int partition(String topic, Object key, byte[] keyBytes, Object value, byte[] valueBytes, Cluster cluster) { throw new UnsupportedOperationException("this method is not used on production anymore"); } default int partition(String topic, Object key, ByteBuffer keyBytes, Object value, ByteBuffer valueBytes, Cluster cluster) { return partition(topic, key, Utils.getOrCopyArray(keyBytes), value, Utils.getOrCopyArray(valueBytes), cluster); } |
...