dengziming commented on PR #12053:
URL: https://github.com/apache/kafka/pull/12053#issuecomment-1099869359
Change output from:
```
[ Kafka Metadata Shell ]
>> ls /configs/broker
>>
```
to
```
[ Kafka Metadata Shell ]
>> ls /configs/broker/
>>
dengziming opened a new pull request, #12053:
URL: https://github.com/apache/kafka/pull/12053
*More detailed description of your change*
When debugging some bugs related to configs, I find we are unable to show
default broker/topic configs since the resourceName="".
I changed it to
showuon commented on code in PR #12024:
URL: https://github.com/apache/kafka/pull/12024#discussion_r851035284
##
core/src/test/scala/unit/kafka/admin/ConfigCommandTest.scala:
##
@@ -479,6 +460,9 @@ class ConfigCommandTest extends QuorumTestHarness with
Logging {
[
https://issues.apache.org/jira/browse/KAFKA-13653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522633#comment-17522633
]
Luke Chen commented on KAFKA-13653:
---
Thanks for pointing it out, [~ijuma] , I've found the old ticket
[
https://issues.apache.org/jira/browse/KAFKA-13653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen resolved KAFKA-13653.
---
Resolution: Duplicate
> Proactively discover alive brokers from bootstrap server lists when all
[
https://issues.apache.org/jira/browse/KAFKA-12495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen reassigned KAFKA-12495:
-
Assignee: (was: Luke Chen)
> Unbalanced connectors/tasks distribution will happen in
[
https://issues.apache.org/jira/browse/KAFKA-12495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522621#comment-17522621
]
Luke Chen commented on KAFKA-12495:
---
I agree this is not a regression and is not a blocker for v3.2.0.
RivenSun2 commented on PR #12041:
URL: https://github.com/apache/kafka/pull/12041#issuecomment-1099797049
In other words, for a configuration (including `unknownConfig`), if neither
Kafka nor the user retrieves this configuration when the KafkaClient completes
initialization, the log
RivenSun2 commented on PR #12041:
URL: https://github.com/apache/kafka/pull/12041#issuecomment-1099790057
Hi @C0urante Thank you for your reply. I see what you mean.
What we now expect is that a configuration is supplied but not used due to
special behavior inside KafkaClient, and we
dengziming commented on PR #11522:
URL: https://github.com/apache/kafka/pull/11522#issuecomment-1099784828
See #12036
--
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.
To
dengziming closed pull request #11522: KAFKA-13242: Ensure UpdateFeatures is
properly handled in KRaft
URL: https://github.com/apache/kafka/pull/11522
--
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
C0urante commented on PR #12041:
URL: https://github.com/apache/kafka/pull/12041#issuecomment-1099784651
@RivenSun2 Isn't this a correct message to log? These properties are unused
if a group ID is supplied, aren't they? That lines up pretty well with the new
log message wording of
C0urante commented on PR #12041:
URL: https://github.com/apache/kafka/pull/12041#issuecomment-1099784467
Isn't this a correct message to log? These properties are unused if a group
ID is supplied, aren't they? That lines up pretty well with the new log message
wording of "supplied but are
[
https://issues.apache.org/jira/browse/KAFKA-13242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dengziming resolved KAFKA-13242.
Resolution: Fixed
> KRaft Controller doesn't handle UpdateFeaturesRequest
>
RivenSun2 commented on PR #12052:
URL: https://github.com/apache/kafka/pull/12052#issuecomment-1099778447
Hi @guozhangwang
could you help to review the PR?
Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
RivenSun2 opened a new pull request, #12052:
URL: https://github.com/apache/kafka/pull/12052
Improve documentation for Kafka zero-copy.
Kafka combines pagecache and zero-copy to greatly improve message
consumption efficiency. But zero-copy only works in PlaintextTransportLayer.
[
https://issues.apache.org/jira/browse/KAFKA-13799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522604#comment-17522604
]
RivenSun edited comment on KAFKA-13799 at 4/15/22 1:35 AM:
---
[~guozhang]
[
https://issues.apache.org/jira/browse/KAFKA-13799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522604#comment-17522604
]
RivenSun edited comment on KAFKA-13799 at 4/15/22 1:35 AM:
---
[~guozhang]
[
https://issues.apache.org/jira/browse/KAFKA-13799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522604#comment-17522604
]
RivenSun commented on KAFKA-13799:
--
[~guozhang]
Thanks for your reply.
Later I will create a minor
[
https://issues.apache.org/jira/browse/KAFKA-13773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-13773:
--
Priority: Critical (was: Major)
> Data loss after recovery from crash due to full hard disk
[
https://issues.apache.org/jira/browse/KAFKA-13773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-13773:
--
Component/s: log
(was: log cleaner)
> Data loss after recovery from
[
https://issues.apache.org/jira/browse/KAFKA-13799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522601#comment-17522601
]
Guozhang Wang commented on KAFKA-13799:
---
[~RivenSun] I agree with you assessment. We can update
RivenSun2 commented on PR #12048:
URL: https://github.com/apache/kafka/pull/12048#issuecomment-1099744951
Ok ,thanks a lot.
--
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.
guozhangwang commented on PR #12048:
URL: https://github.com/apache/kafka/pull/12048#issuecomment-1099744235
I think just removing it is fine.
--
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
RivenSun2 commented on PR #12048:
URL: https://github.com/apache/kafka/pull/12048#issuecomment-1099743628
@guozhangwang
Sorry, I originally wanted to resubmit an edit, it might be easier to read
and understand.
`if (sendFailed || !hasPending)`
WDYT？
Thanks.
--
This is an
guozhangwang commented on PR #12041:
URL: https://github.com/apache/kafka/pull/12041#issuecomment-1099741042
LGTM. Merged to trunk.
--
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
guozhangwang merged PR #12041:
URL: https://github.com/apache/kafka/pull/12041
--
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.
To unsubscribe, e-mail:
RivenSun2 commented on PR #12048:
URL: https://github.com/apache/kafka/pull/12048#issuecomment-1099740076
Thanks, i just deleted my last comment, because it's wrong.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
guozhangwang commented on PR #12030:
URL: https://github.com/apache/kafka/pull/12030#issuecomment-1099739916
@lihaosky The jenkins build failed on the following:
```
guozhangwang commented on PR #12030:
URL: https://github.com/apache/kafka/pull/12030#issuecomment-1099739650
Re-triggered jenkins, will merge if we can have a green build.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
guozhangwang commented on code in PR #12030:
URL: https://github.com/apache/kafka/pull/12030#discussion_r850922180
##
streams/src/main/java/org/apache/kafka/streams/state/internals/TimeOrderedCachingWindowStore.java:
##
@@ -0,0 +1,694 @@
+/*
+ * Licensed to the Apache Software
guozhangwang merged PR #12048:
URL: https://github.com/apache/kafka/pull/12048
--
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.
To unsubscribe, e-mail:
guozhangwang commented on PR #12048:
URL: https://github.com/apache/kafka/pull/12048#issuecomment-1099739013
> There may be a problem with the logic of this code, missing a case:
> when `sendFailed` is true, `doClose` should also be executed.
I see what you mean now. I think it's
cmccabe commented on code in PR #12033:
URL: https://github.com/apache/kafka/pull/12033#discussion_r850918223
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -1602,13 +1651,21 @@ public CompletableFuture beginWritingSnapshot() {
}
cmccabe commented on code in PR #12033:
URL: https://github.com/apache/kafka/pull/12033#discussion_r850917391
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -582,16 +582,17 @@ ReplicationControlManager replicationControl() {
return
RivenSun2 commented on PR #12048:
URL: https://github.com/apache/kafka/pull/12048#issuecomment-1099734098
@guozhangwang
There may be a problem with the logic of this code, missing a case:
when `sendFailed` is true, `doClose` should also be executed.
--
This is an automated message
cmccabe commented on code in PR #12033:
URL: https://github.com/apache/kafka/pull/12033#discussion_r850913141
##
core/src/main/scala/kafka/log/LogConfig.scala:
##
@@ -473,8 +473,8 @@ object LogConfig {
FlushMessagesProp -> asList(
new
mumrah closed pull request #11677: KAFKA-13410 Add KRaft metadata.version for
KIP-778
URL: https://github.com/apache/kafka/pull/11677
--
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
mumrah commented on PR #11677:
URL: https://github.com/apache/kafka/pull/11677#issuecomment-1099729093
The `metadata.version` parts of this PR were split out into
https://github.com/apache/kafka/pull/12050
--
This is an automated message from the Apache Git Service.
To respond to the
RivenSun2 commented on PR #12048:
URL: https://github.com/apache/kafka/pull/12048#issuecomment-1099693054
Hi @guozhangwang yes i understand what you mean.
`// Remove closed channels after all their buffered receives have been
processed or if a send was requested
for
[
https://issues.apache.org/jira/browse/KAFKA-8178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522550#comment-17522550
]
Guozhang Wang commented on KAFKA-8178:
--
I think it's fair to update the docs to explicitly state
lihaosky commented on code in PR #12030:
URL: https://github.com/apache/kafka/pull/12030#discussion_r850851250
##
streams/src/main/java/org/apache/kafka/streams/state/internals/TimeOrderedCachingWindowStore.java:
##
@@ -0,0 +1,694 @@
+/*
+ * Licensed to the Apache Software
guozhangwang commented on code in PR #12044:
URL: https://github.com/apache/kafka/pull/12044#discussion_r850797609
##
clients/src/test/java/org/apache/kafka/common/utils/ExponentialBackoffTest.java:
##
@@ -20,30 +20,42 @@
import org.junit.jupiter.api.Test;
import static
ehumber commented on code in PR #7283:
URL: https://github.com/apache/kafka/pull/7283#discussion_r850798257
##
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java:
##
@@ -1053,6 +1048,14 @@ private ClusterAndWaitTime waitOnMetadata(String topic,
Integer
guozhangwang commented on code in PR #12030:
URL: https://github.com/apache/kafka/pull/12030#discussion_r850788768
##
streams/src/main/java/org/apache/kafka/streams/state/internals/PrefixedWindowKeySchemas.java:
##
@@ -34,13 +34,17 @@ public class PrefixedWindowKeySchemas {
cadonna merged PR #12051:
URL: https://github.com/apache/kafka/pull/12051
--
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.
To unsubscribe, e-mail:
cadonna opened a new pull request, #12051:
URL: https://github.com/apache/kafka/pull/12051
Updates the license file.
Validate with
`./gradlewAll releaseTarGz`
`tar xf core/build/distributions/kafka_2.13-3.3.0-SNAPSHOT.tgz`
`cd xf kafka_2.13-3.3.0-SNAPSHOT`
`for f in
[
https://issues.apache.org/jira/browse/KAFKA-12622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-12622:
--
Fix Version/s: 3.3.0
(was: 3.2.0)
> Automate LICENSE file validation
>
[
https://issues.apache.org/jira/browse/KAFKA-8391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-8391:
-
Priority: Critical (was: Blocker)
> Flaky Test
[
https://issues.apache.org/jira/browse/KAFKA-12283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-12283:
--
Fix Version/s: (was: 3.2.0)
> Flaky Test
>
[
https://issues.apache.org/jira/browse/KAFKA-8391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-8391:
-
Fix Version/s: (was: 3.2.0)
> Flaky Test
[
https://issues.apache.org/jira/browse/KAFKA-12283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-12283:
--
Priority: Critical (was: Blocker)
> Flaky Test
>
gitlw commented on code in PR #12029:
URL: https://github.com/apache/kafka/pull/12029#discussion_r850757573
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -2615,7 +2615,10 @@ class ReplicaManagerTest {
@Test
def
[
https://issues.apache.org/jira/browse/KAFKA-12495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-12495:
--
Priority: Critical (was: Blocker)
> Unbalanced connectors/tasks distribution will happen in
[
https://issues.apache.org/jira/browse/KAFKA-12495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-12495:
--
Fix Version/s: (was: 3.2.0)
> Unbalanced connectors/tasks distribution will happen in
mumrah opened a new pull request, #12050:
URL: https://github.com/apache/kafka/pull/12050
This patch includes a new metadata.version which is planned to replace IBP in
KRaft clusters. The kafka-storage tool now allows a user to specify a
specific
metadata.version to bootstrap into the
[
https://issues.apache.org/jira/browse/KAFKA-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522502#comment-17522502
]
Matthias J. Sax edited comment on KAFKA-12909 at 4/14/22 7:12 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522502#comment-17522502
]
Matthias J. Sax commented on KAFKA-12909:
-
{quote}It makes sense but it is still kind of hard to
David Arthur created KAFKA-13830:
Summary: Introduce metadata.version in KRaft
Key: KAFKA-13830
URL: https://issues.apache.org/jira/browse/KAFKA-13830
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-13823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur resolved KAFKA-13823.
--
Fix Version/s: 3.3.0
Resolution: Fixed
> Remove "max" version level from finalized
lihaosky commented on code in PR #12030:
URL: https://github.com/apache/kafka/pull/12030#discussion_r850689043
##
streams/src/main/java/org/apache/kafka/streams/state/internals/TimeOrderedCachingWindowStore.java:
##
@@ -0,0 +1,694 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/KAFKA-12495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522472#comment-17522472
]
Chris Egerton commented on KAFKA-12495:
---
I believe the risks of rebalance storms are being
junrao commented on code in PR #12029:
URL: https://github.com/apache/kafka/pull/12029#discussion_r850679270
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -2615,7 +2615,10 @@ class ReplicaManagerTest {
@Test
def
[
https://issues.apache.org/jira/browse/KAFKA-12495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522464#comment-17522464
]
Konstantine Karantasis commented on KAFKA-12495:
With respect to release logistics, I
wcarlson5 commented on code in PR #12044:
URL: https://github.com/apache/kafka/pull/12044#discussion_r849921212
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskExecutor.java:
##
@@ -223,15 +227,15 @@ void commitOffsetsOrTransaction(final Map
gitlw commented on code in PR #12029:
URL: https://github.com/apache/kafka/pull/12029#discussion_r850665758
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -573,9 +576,14 @@ class UnifiedLog(@volatile var logStartOffset: Long,
case None =>
if
gitlw commented on code in PR #12029:
URL: https://github.com/apache/kafka/pull/12029#discussion_r850665085
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -2615,7 +2615,10 @@ class ReplicaManagerTest {
@Test
def
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,
gitlw commented on code in PR #12029:
URL: https://github.com/apache/kafka/pull/12029#discussion_r850657561
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -2615,7 +2615,10 @@ class ReplicaManagerTest {
@Test
def
gitlw commented on code in PR #12029:
URL: https://github.com/apache/kafka/pull/12029#discussion_r850657561
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -2615,7 +2615,10 @@ class ReplicaManagerTest {
@Test
def
Ge commented on code in PR #11945:
URL: https://github.com/apache/kafka/pull/11945#discussion_r850656607
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResponseWrapper.java:
##
@@ -21,22 +21,30 @@
import java.util.Arrays;
Ge commented on code in PR #11945:
URL: https://github.com/apache/kafka/pull/11945#discussion_r850656191
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapperSerde.java:
##
@@ -141,17 +204,29 @@ public SubscriptionWrapper
Ge commented on code in PR #11945:
URL: https://github.com/apache/kafka/pull/11945#discussion_r850653002
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapper.java:
##
@@ -23,12 +23,15 @@
public class SubscriptionWrapper
Ge commented on code in PR #11945:
URL: https://github.com/apache/kafka/pull/11945#discussion_r850652693
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResponseWrapper.java:
##
@@ -21,22 +21,30 @@
import java.util.Arrays;
junrao commented on code in PR #10826:
URL: https://github.com/apache/kafka/pull/10826#discussion_r849786048
##
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java:
##
@@ -523,6 +532,45 @@ boolean idempotenceEnabled() {
return
cmccabe commented on PR #12036:
URL: https://github.com/apache/kafka/pull/12036#issuecomment-1099415675
Thanks, @mumrah. Committed.
--
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
cmccabe merged PR #12036:
URL: https://github.com/apache/kafka/pull/12036
--
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.
To unsubscribe, e-mail:
artemlivshits opened a new pull request, #12049:
URL: https://github.com/apache/kafka/pull/12049
The design is described in detail in KIP-794
https://cwiki.apache.org/confluence/display/KAFKA/KIP-794%3A+Strictly+Uniform+Sticky+Partitioner.
Implementation notes:
The default
ijuma commented on code in PR #10826:
URL: https://github.com/apache/kafka/pull/10826#discussion_r850515974
##
clients/src/main/java/org/apache/kafka/common/compress/KafkaLZ4BlockOutputStream.java:
##
@@ -41,6 +41,10 @@ public final class KafkaLZ4BlockOutputStream extends
ijuma commented on code in PR #10826:
URL: https://github.com/apache/kafka/pull/10826#discussion_r850514430
##
clients/src/main/java/org/apache/kafka/common/compress/GzipOutputStream.java:
##
@@ -0,0 +1,48 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
ijuma commented on code in PR #10826:
URL: https://github.com/apache/kafka/pull/10826#discussion_r850511813
##
clients/src/main/java/org/apache/kafka/common/compress/GzipOutputStream.java:
##
@@ -0,0 +1,48 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
ijuma commented on code in PR #10826:
URL: https://github.com/apache/kafka/pull/10826#discussion_r850510536
##
clients/src/main/java/org/apache/kafka/common/compress/GzipConfig.java:
##
@@ -0,0 +1,87 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
ijuma commented on code in PR #10826:
URL: https://github.com/apache/kafka/pull/10826#discussion_r850509560
##
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java:
##
@@ -523,6 +532,45 @@ boolean idempotenceEnabled() {
return
ijuma commented on code in PR #10826:
URL: https://github.com/apache/kafka/pull/10826#discussion_r850506417
##
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java:
##
@@ -188,6 +190,12 @@ public class ProducerConfig extends AbstractConfig {
ijuma commented on PR #10826:
URL: https://github.com/apache/kafka/pull/10826#issuecomment-1099245217
@mimaison yeah, I just edited my message. :)
--
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
mimaison commented on PR #10826:
URL: https://github.com/apache/kafka/pull/10826#issuecomment-1099244913
As far as I can tell this is implementing KIP-390 and it received 3 binding
votes: https://lists.apache.org/thread/wnd6ky3kjzv9gkzc39qy5gg2pp20ovs1
--
This is an automated message
ijuma commented on PR #10826:
URL: https://github.com/apache/kafka/pull/10826#issuecomment-1099240705
@mimaison fyi, I think we need more votes in the KIP thread.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
mimaison commented on code in PR #10826:
URL: https://github.com/apache/kafka/pull/10826#discussion_r850466685
##
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java:
##
@@ -188,6 +190,12 @@ public class ProducerConfig extends AbstractConfig {
[
https://issues.apache.org/jira/browse/KAFKA-12495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522328#comment-17522328
]
Bruno Cadonna commented on KAFKA-12495:
---
[~showuon] [~ChrisEgerton] [~kkonstantine] Is this a
[
https://issues.apache.org/jira/browse/KAFKA-13827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur updated KAFKA-13827:
-
Component/s: kraft
> Data Loss on moving to KRAFT mode from v3.1
>
[
https://issues.apache.org/jira/browse/KAFKA-13827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522327#comment-17522327
]
David Arthur commented on KAFKA-13827:
--
[~gargsha] by "v2.8/v3.1", do you mean you were running IBP
[
https://issues.apache.org/jira/browse/KAFKA-13653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522326#comment-17522326
]
Ismael Juma commented on KAFKA-13653:
-
This is a long-standing issue and there's already a Jira for
ijuma commented on code in PR #7283:
URL: https://github.com/apache/kafka/pull/7283#discussion_r850457061
##
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java:
##
@@ -1032,18 +1032,13 @@ private ClusterAndWaitTime waitOnMetadata(String topic,
Integer
ijuma commented on code in PR #7283:
URL: https://github.com/apache/kafka/pull/7283#discussion_r850452641
##
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java:
##
@@ -1053,6 +1048,14 @@ private ClusterAndWaitTime waitOnMetadata(String topic,
Integer
showuon commented on PR #10367:
URL: https://github.com/apache/kafka/pull/10367#issuecomment-1099185348
My comment is put in [jira
ticket](https://issues.apache.org/jira/browse/KAFKA-12495). Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message,
cadonna commented on PR #10367:
URL: https://github.com/apache/kafka/pull/10367#issuecomment-1099159615
@kkonstantine Thank you for your thoughts! From a 3.2.0 release perspective
your proposal seems to be a change that we should postpone to a later release
since feature freeze and code
[
https://issues.apache.org/jira/browse/KAFKA-13829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522282#comment-17522282
]
RivenSun commented on KAFKA-13829:
--
> we are saying that we can send the subsequent request without
[
https://issues.apache.org/jira/browse/KAFKA-13829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522271#comment-17522271
]
Ismael Juma edited comment on KAFKA-13829 at 4/14/22 12:26 PM:
---
I think
[
https://issues.apache.org/jira/browse/KAFKA-13829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522271#comment-17522271
]
Ismael Juma commented on KAFKA-13829:
-
I think this is behaving as expected. We are not saying that
[
https://issues.apache.org/jira/browse/KAFKA-13664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522215#comment-17522215
]
Vyacheslav Ksenz commented on KAFKA-13664:
--
Hi! There is no reaction to ticket for two months.
1 - 100 of 124 matches
Mail list logo
