[GitHub] [kafka] artemlivshits commented on a diff in pull request #12049: KAFKA-10888: Sticky partition leads to uneven produce msg

2022-06-29 Thread GitBox
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,

[GitHub] [kafka] artemlivshits commented on a diff in pull request #12049: KAFKA-10888: Sticky partition leads to uneven produce msg

2022-06-29 Thread GitBox
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,

[GitHub] [kafka] artemlivshits commented on a diff in pull request #12049: KAFKA-10888: Sticky partition leads to uneven produce msg

2022-05-05 Thread GitBox
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

[GitHub] [kafka] artemlivshits commented on a diff in pull request #12049: KAFKA-10888: Sticky partition leads to uneven produce msg

2022-05-05 Thread GitBox
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

[GitHub] [kafka] artemlivshits commented on a diff in pull request #12049: KAFKA-10888: Sticky partition leads to uneven produce msg

2022-05-04 Thread GitBox
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

[GitHub] [kafka] artemlivshits commented on a diff in pull request #12049: KAFKA-10888: Sticky partition leads to uneven produce msg

2022-04-29 Thread GitBox
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, * *

[GitHub] [kafka] artemlivshits commented on a diff in pull request #12049: KAFKA-10888: Sticky partition leads to uneven produce msg

2022-04-29 Thread GitBox
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

[GitHub] [kafka] artemlivshits commented on a diff in pull request #12049: KAFKA-10888: Sticky partition leads to uneven produce msg

2022-04-28 Thread GitBox
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

[GitHub] [kafka] artemlivshits commented on a diff in pull request #12049: KAFKA-10888: Sticky partition leads to uneven produce msg

2022-04-22 Thread GitBox
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

[GitHub] [kafka] artemlivshits commented on a diff in pull request #12049: KAFKA-10888: Sticky partition leads to uneven produce msg

2022-04-14 Thread GitBox
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,