artemlivshits commented on code in PR #12049:
URL: https://github.com/apache/kafka/pull/12049#discussion_r910500293
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java:
##
@@ -160,91 +220,162 @@ public double measure(MetricConfig config,
artemlivshits commented on code in PR #12049:
URL: https://github.com/apache/kafka/pull/12049#discussion_r910265594
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java:
##
@@ -160,91 +220,162 @@ public double measure(MetricConfig config,
artemlivshits commented on code in PR #12049:
URL: https://github.com/apache/kafka/pull/12049#discussion_r866402725
##
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java:
##
@@ -1403,25 +1452,54 @@ public boolean isDone() {
}
/**
- * A
artemlivshits commented on code in PR #12049:
URL: https://github.com/apache/kafka/pull/12049#discussion_r866386035
##
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java:
##
@@ -1403,25 +1452,54 @@ public boolean isDone() {
}
/**
- * A
artemlivshits commented on code in PR #12049:
URL: https://github.com/apache/kafka/pull/12049#discussion_r865302205
##
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java:
##
@@ -960,8 +1002,10 @@ private Future doSend(ProducerRecord record, Callback call
artemlivshits commented on code in PR #12049:
URL: https://github.com/apache/kafka/pull/12049#discussion_r861378007
##
clients/src/main/java/org/apache/kafka/clients/producer/MockProducer.java:
##
@@ -117,10 +116,24 @@ public MockProducer(final Cluster cluster,
*
*
artemlivshits commented on code in PR #12049:
URL: https://github.com/apache/kafka/pull/12049#discussion_r861379747
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/BuiltInPartitioner.java:
##
@@ -0,0 +1,281 @@
+/*
+ * Licensed to the Apache Software
artemlivshits commented on code in PR #12049:
URL: https://github.com/apache/kafka/pull/12049#discussion_r861185234
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/BuiltInPartitioner.java:
##
@@ -0,0 +1,334 @@
+/*
+ * Licensed to the Apache Software
artemlivshits commented on code in PR #12049:
URL: https://github.com/apache/kafka/pull/12049#discussion_r855698824
##
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java:
##
@@ -1321,21 +1339,30 @@ private ClusterResourceListeners
artemlivshits commented on code in PR #12049:
URL: https://github.com/apache/kafka/pull/12049#discussion_r850625357
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerBatch.java:
##
@@ -103,7 +103,18 @@ public ProducerBatch(TopicPartition tp,
10 matches
Mail list logo