jolshan commented on a change in pull request #10590:
URL: https://github.com/apache/kafka/pull/10590#discussion_r620608169



##########
File path: 
clients/src/main/java/org/apache/kafka/clients/producer/Partitioner.java
##########
@@ -34,10 +34,9 @@
      * @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 or null
-     * @param valueBytes The serialized value to partition on or null
      * @param cluster The current cluster metadata
      */
-    public int partition(String topic, Object key, byte[] keyBytes, Object 
value, byte[] valueBytes, Cluster cluster);

Review comment:
       This is a public interface, so we can't change the parameters without a 
KIP. We need to consider compatibility with others who may be using the old 
interface. This is likely why this parameter still exists.  See 
https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals.




-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Reply via email to