divijvaidya commented on PR #14695:
URL: https://github.com/apache/kafka/pull/14695#issuecomment-1798003212
@jolshan @splett2 are we planning this to backport to 3.6 & 3.5 as well?
This will help stabilize tests during version release for 3.5.2 and 3.6.1.
--
This is an automated message f
divijvaidya commented on PR #14674:
URL: https://github.com/apache/kafka/pull/14674#issuecomment-1798039418
Test failures and build failure is unrelated:
```
[Build / JDK 21 and Scala 2.13 /
org.apache.kafka.connect.integration.OffsetsApiIntegrationTest.testAlterSinkConnectorOffsetsZom
divijvaidya merged PR #14674:
URL: https://github.com/apache/kafka/pull/14674
--
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: jira-unsubscr...@kafka.apa
[
https://issues.apache.org/jira/browse/KAFKA-15771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-15771:
-
Fix Version/s: 3.7.0
> ProduceRequest#partitionSizes() is not an atomic operation
> ---
[
https://issues.apache.org/jira/browse/KAFKA-15771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya reassigned KAFKA-15771:
Assignee: Xiaobing Fang
> ProduceRequest#partitionSizes() is not an atomic operation
> -
[
https://issues.apache.org/jira/browse/KAFKA-15771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-15771:
-
Fix Version/s: 3.5.2
3.6.1
> ProduceRequest#partitionSizes() is not an atomi
[
https://issues.apache.org/jira/browse/KAFKA-15771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya resolved KAFKA-15771.
--
Resolution: Fixed
> ProduceRequest#partitionSizes() is not an atomic operation
>
divijvaidya merged PR #14613:
URL: https://github.com/apache/kafka/pull/14613
--
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: jira-unsubscr...@kafka.apa
linzihao1999 opened a new pull request, #14707:
URL: https://github.com/apache/kafka/pull/14707
The tests in KafkaMetricReporterExceptionHandlingTest in
core/src/test/scala/unit/kafka/server/KafkaMetricReporterExceptionHandlingTest.scala
updated to support KRaft.
### Committer Checkl
[
https://issues.apache.org/jira/browse/KAFKA-15750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zihao Lin reassigned KAFKA-15750:
-
Assignee: Zihao Lin
> KRaft support in KafkaMetricReporterExceptionHandlingTest
> -
[
https://issues.apache.org/jira/browse/KAFKA-15513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783547#comment-17783547
]
Daniele Carminati commented on KAFKA-15513:
---
So [~pprovenzano] it is logicall
[
https://issues.apache.org/jira/browse/KAFKA-15513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783547#comment-17783547
]
Daniele Carminati edited comment on KAFKA-15513 at 11/7/23 9:36 AM:
--
[
https://issues.apache.org/jira/browse/KAFKA-15780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-15780:
-
Fix Version/s: 3.7.0
> Wait for consistent kraft metadata when creating topics in tests
> --
[
https://issues.apache.org/jira/browse/KAFKA-15780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya reassigned KAFKA-15780:
Assignee: David Mao
> Wait for consistent kraft metadata when creating topics in tests
>
divijvaidya commented on PR #14688:
URL: https://github.com/apache/kafka/pull/14688#issuecomment-1798148188
Merged to 3.6 branch as well to provide stable tests for upcoming 3.6.1
release
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
[
https://issues.apache.org/jira/browse/KAFKA-15760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-15760:
-
Labels: flaky-test (was: )
> org.apache.kafka.trogdor.coordinator.CoordinatorTest.testTaskReque
[
https://issues.apache.org/jira/browse/KAFKA-15759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-15759:
-
Labels: flaky-test (was: )
> DescribeClusterRequestTest is flaky
>
[
https://issues.apache.org/jira/browse/KAFKA-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783559#comment-17783559
]
Divij Vaidya commented on KAFKA-15388:
--
Hey [~goyarpit] - apologies for the delay.
showuon commented on PR #14428:
URL: https://github.com/apache/kafka/pull/14428#issuecomment-1798236911
@jsancio @ahuang98 , do you have any other comments? I'd like to include
this fix into v3.5.2 if possible. Thanks.
--
This is an automated message from the Apache Git Service.
To respon
showuon commented on PR #14631:
URL: https://github.com/apache/kafka/pull/14631#issuecomment-1798287568
@mumrah, could you take a look when available? Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abo
tinaselenge commented on code in PR #14707:
URL: https://github.com/apache/kafka/pull/14707#discussion_r1384842111
##
core/src/test/scala/unit/kafka/server/KafkaMetricReporterExceptionHandlingTest.scala:
##
@@ -50,19 +52,30 @@ class KafkaMetricReporterExceptionHandlingTest exten
tinaselenge commented on code in PR #14595:
URL: https://github.com/apache/kafka/pull/14595#discussion_r1384847563
##
core/src/test/scala/integration/kafka/api/ProducerSendWhileDeletionTest.scala:
##
@@ -1,83 +1,87 @@
/**
- * Licensed to the Apache Software Foundation (ASF) un
[
https://issues.apache.org/jira/browse/KAFKA-15707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zihao Lin reassigned KAFKA-15707:
-
Assignee: Zihao Lin
> KRaft support in TopicBasedRemoteLogMetadataManagerHarness
>
linzihao1999 commented on code in PR #14707:
URL: https://github.com/apache/kafka/pull/14707#discussion_r1384872182
##
core/src/test/scala/unit/kafka/server/KafkaMetricReporterExceptionHandlingTest.scala:
##
@@ -50,19 +52,30 @@ class KafkaMetricReporterExceptionHandlingTest exte
dajac commented on code in PR #14670:
URL: https://github.com/apache/kafka/pull/14670#discussion_r1384566593
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerDelegate.java:
##
@@ -0,0 +1,36 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) u
tinaselenge commented on code in PR #14707:
URL: https://github.com/apache/kafka/pull/14707#discussion_r1384937097
##
core/src/test/scala/unit/kafka/server/KafkaMetricReporterExceptionHandlingTest.scala:
##
@@ -50,19 +52,30 @@ class KafkaMetricReporterExceptionHandlingTest exten
tinaselenge commented on code in PR #14595:
URL: https://github.com/apache/kafka/pull/14595#discussion_r1384847563
##
core/src/test/scala/integration/kafka/api/ProducerSendWhileDeletionTest.scala:
##
@@ -1,83 +1,87 @@
/**
- * Licensed to the Apache Software Foundation (ASF) un
ex172000 commented on code in PR #14701:
URL: https://github.com/apache/kafka/pull/14701#discussion_r1384984849
##
docs/streams/architecture.html:
##
@@ -148,7 +148,8 @@ Log compaction is
enabled on the changelog topics so that old data can be purged safely to
prevent the topi
ex172000 commented on code in PR #14707:
URL: https://github.com/apache/kafka/pull/14707#discussion_r1385007171
##
core/src/test/scala/unit/kafka/server/KafkaMetricReporterExceptionHandlingTest.scala:
##
@@ -50,19 +52,30 @@ class KafkaMetricReporterExceptionHandlingTest extends
linzihao1999 commented on code in PR #14707:
URL: https://github.com/apache/kafka/pull/14707#discussion_r1385016361
##
core/src/test/scala/unit/kafka/server/KafkaMetricReporterExceptionHandlingTest.scala:
##
@@ -50,19 +52,30 @@ class KafkaMetricReporterExceptionHandlingTest exte
linzihao1999 commented on code in PR #14707:
URL: https://github.com/apache/kafka/pull/14707#discussion_r1385018004
##
core/src/test/scala/unit/kafka/server/KafkaMetricReporterExceptionHandlingTest.scala:
##
@@ -50,19 +52,30 @@ class KafkaMetricReporterExceptionHandlingTest exte
lianetm commented on code in PR #14690:
URL: https://github.com/apache/kafka/pull/14690#discussion_r1385059304
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/PrototypeAsyncConsumer.java:
##
@@ -843,7 +845,15 @@ private void updatePatternSubscription(Cluster
lianetm commented on code in PR #14690:
URL: https://github.com/apache/kafka/pull/14690#discussion_r1385082158
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java:
##
@@ -181,33 +307,469 @@ public void
updateState(ConsumerGroupHeartbe
lianetm commented on code in PR #14690:
URL: https://github.com/apache/kafka/pull/14690#discussion_r1385085418
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java:
##
@@ -181,33 +262,465 @@ public void
updateState(ConsumerGroupHeartbe
chb2ab commented on code in PR #1:
URL: https://github.com/apache/kafka/pull/1#discussion_r1385095201
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -562,6 +562,26 @@ class KafkaApis(val requestChannel: RequestChannel,
}
}
+ case class LeaderNode(l
mumrah merged PR #14594:
URL: https://github.com/apache/kafka/pull/14594
--
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: jira-unsubscr...@kafka.apache.o
[
https://issues.apache.org/jira/browse/KAFKA-13530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783687#comment-17783687
]
Kirk True commented on KAFKA-13530:
---
I also can't reproduce the flakiness on latest tr
jolshan commented on code in PR #1:
URL: https://github.com/apache/kafka/pull/1#discussion_r1385219521
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -562,6 +562,26 @@ class KafkaApis(val requestChannel: RequestChannel,
}
}
+ case class LeaderNode(
[
https://issues.apache.org/jira/browse/KAFKA-13530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783691#comment-17783691
]
Kirk True commented on KAFKA-13530:
---
Out of the last 333 runs on trunk, there were no
[
https://issues.apache.org/jira/browse/KAFKA-13530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783691#comment-17783691
]
Kirk True edited comment on KAFKA-13530 at 11/7/23 4:42 PM:
jeffkbkim commented on PR #14387:
URL: https://github.com/apache/kafka/pull/14387#issuecomment-1799261509
> Also @jeffkbkim can you check the build? Seems like something is off.
thanks, i'll take a look
> Ah got it, so whether we are adding new or loading from the log we will
a
[
https://issues.apache.org/jira/browse/KAFKA-15020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783708#comment-17783708
]
Kirk True commented on KAFKA-15020:
---
According to [historical test runs over the last
AyoubOm commented on code in PR #14701:
URL: https://github.com/apache/kafka/pull/14701#discussion_r1385285680
##
docs/streams/architecture.html:
##
@@ -148,7 +148,8 @@ Log compaction is
enabled on the changelog topics so that old data can be purged safely to
prevent the topic
[
https://issues.apache.org/jira/browse/KAFKA-15575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton reassigned KAFKA-15575:
-
Assignee: Chris Egerton
> Prevent Connectors from exceeding tasks.max configuration
> -
[
https://issues.apache.org/jira/browse/KAFKA-15575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-15575:
--
Labels: kip (was: )
> Prevent Connectors from exceeding tasks.max configuration
> ---
agavra opened a new pull request, #14708:
URL: https://github.com/apache/kafka/pull/14708
This is a follow up from #14659 that ports the windowed classes to use the
`StoreFactory` abstraction as well. There's a side benefit of not duplicating
the materialization code twice for each `StreamI
agavra commented on code in PR #14708:
URL: https://github.com/apache/kafka/pull/14708#discussion_r1385298963
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowStoreMaterializer.java:
##
@@ -0,0 +1,133 @@
+/*
+ * Licensed to the Apache Software Founda
jeffkbkim commented on code in PR #14387:
URL: https://github.com/apache/kafka/pull/14387#discussion_r1385307246
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorShard.java:
##
@@ -160,11 +161,14 @@ public GroupCoordinatorShard build() {
cadonna opened a new pull request, #14709:
URL: https://github.com/apache/kafka/pull/14709
When a task is corrupted, uncorrupted tasks are committed. That is also true
for standby tasks. Committing standby tasks actually means that they are
checkpointed.
When the state updater is ena
jeffkbkim commented on code in PR #14387:
URL: https://github.com/apache/kafka/pull/14387#discussion_r1385317000
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -120,6 +121,9 @@
import static
org.apache.kafka.coordinator.g
philipnee commented on code in PR #14690:
URL: https://github.com/apache/kafka/pull/14690#discussion_r1383658863
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java:
##
@@ -166,19 +166,41 @@ private static long findMinTime(final Collect
lianetm commented on code in PR #14690:
URL: https://github.com/apache/kafka/pull/14690#discussion_r1385350785
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java:
##
@@ -181,33 +256,465 @@ public void
updateState(ConsumerGroupHeartbe
pprovenzano commented on code in PR #14369:
URL: https://github.com/apache/kafka/pull/14369#discussion_r1385385403
##
core/src/main/scala/kafka/server/ReplicaManager.scala:
##
@@ -2296,13 +2298,41 @@ class ReplicaManager(val config: KafkaConfig,
if (sendZkNotification)
jolshan commented on PR #14695:
URL: https://github.com/apache/kafka/pull/14695#issuecomment-1799528544
I can do that if we think it is useful.
--
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
pprovenzano commented on code in PR #14369:
URL: https://github.com/apache/kafka/pull/14369#discussion_r1385399770
##
core/src/main/java/kafka/server/AssignmentsManager.java:
##
@@ -0,0 +1,386 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * cont
junrao commented on code in PR #14705:
URL: https://github.com/apache/kafka/pull/14705#discussion_r1385389618
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntime.java:
##
@@ -659,9 +660,21 @@ public TopicPartition key() {
*/
jolshan commented on PR #14629:
URL: https://github.com/apache/kafka/pull/14629#issuecomment-1799582958
I took a look at the most recent 19 failures. The majority of them are
failing on trunk in the last few (5 or so) runs.
I will take a look at the remaining ones I didn't see failing on
chb2ab commented on code in PR #1:
URL: https://github.com/apache/kafka/pull/1#discussion_r1385430343
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -562,6 +562,26 @@ class KafkaApis(val requestChannel: RequestChannel,
}
}
+ case class LeaderNode(l
[
https://issues.apache.org/jira/browse/KAFKA-13627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783750#comment-17783750
]
Ben Ellis commented on KAFKA-13627:
---
Discussion on KIP-816 seems to have gone idle sin
C0urante commented on code in PR #14704:
URL: https://github.com/apache/kafka/pull/14704#discussion_r1385398359
##
connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectStandalone.java:
##
@@ -87,6 +98,61 @@ protected void processExtraArgs(Herder herder, Connect
con
jolshan commented on code in PR #1:
URL: https://github.com/apache/kafka/pull/1#discussion_r1385453402
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -562,6 +562,26 @@ class KafkaApis(val requestChannel: RequestChannel,
}
}
+ case class LeaderNode(
[
https://issues.apache.org/jira/browse/KAFKA-15546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783769#comment-17783769
]
Raman Verma commented on KAFKA-15546:
-
[~hifly81] I have opened this KIP for changes
pprovenzano commented on PR #14392:
URL: https://github.com/apache/kafka/pull/14392#issuecomment-1799807037
So, I think here we just want to set the list of directory UUIDs that we
know about and assume they are online. We can later set a known directory to
offline with our first heartbeat.
artemlivshits commented on code in PR #14705:
URL: https://github.com/apache/kafka/pull/14705#discussion_r1385493045
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntime.java:
##
@@ -659,9 +660,21 @@ public TopicPartition key() {
chb2ab commented on code in PR #1:
URL: https://github.com/apache/kafka/pull/1#discussion_r1385525549
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -562,6 +562,26 @@ class KafkaApis(val requestChannel: RequestChannel,
}
}
+ case class LeaderNode(l
philipnee opened a new pull request, #14710:
URL: https://github.com/apache/kafka/pull/14710
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of testi
apoorvmittal10 commented on PR #14632:
URL: https://github.com/apache/kafka/pull/14632#issuecomment-1800093637
@junrao @hachikuji @AndrewJSchofield @mjsax Please if I can get the feedback
on the PR.
--
This is an automated message from the Apache Git Service.
To respond to the message, pl
apoorvmittal10 commented on PR #14699:
URL: https://github.com/apache/kafka/pull/14699#issuecomment-1800097217
@junrao @hachikuji @AndrewJSchofield @mjsax Please if I can get feedback on
the PR.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
junrao commented on PR #14629:
URL: https://github.com/apache/kafka/pull/14629#issuecomment-1800110570
@jolshan : Thanks for the analysis. If the test failures are unrelated, feel
free to merge the PR. It would be useful to file jiras to track new transient
test failures.
--
This is an a
cmccabe commented on PR #14628:
URL: https://github.com/apache/kafka/pull/14628#issuecomment-1800111262
> This PR does not work for ZK. You cannot create the directories in
LogManager.scala but then write the directoryIds later. The directoryIds must
be generated either when LogManager sca
kirktrue commented on code in PR #14670:
URL: https://github.com/apache/kafka/pull/14670#discussion_r1385612995
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/LegacyKafkaConsumer.java:
##
@@ -0,0 +1,2554 @@
+/*
+ * Licensed to the Apache Software Foundation
lihaosky opened a new pull request, #14711:
URL: https://github.com/apache/kafka/pull/14711
Adding config for rack aware assignment strategy which will compute
assignment with min cost and balance tasks of same subtopology to different
clients
### Committer Checklist (excluded from c
kirktrue commented on code in PR #14670:
URL: https://github.com/apache/kafka/pull/14670#discussion_r1385614421
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerDelegate.java:
##
@@ -0,0 +1,36 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF
kirktrue commented on code in PR #14670:
URL: https://github.com/apache/kafka/pull/14670#discussion_r1385615790
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerDelegate.java:
##
@@ -0,0 +1,36 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF
[
https://issues.apache.org/jira/browse/KAFKA-15759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783798#comment-17783798
]
Justine Olshan commented on KAFKA-15759:
Think this might be a duplicate of KAFK
[
https://issues.apache.org/jira/browse/KAFKA-15760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783799#comment-17783799
]
Justine Olshan commented on KAFKA-15760:
I also saw this failing today.
> org.a
[
https://issues.apache.org/jira/browse/KAFKA-15700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783800#comment-17783800
]
Justine Olshan commented on KAFKA-15700:
Also saw this one :)
KAFKA-15020 and K
kirktrue commented on code in PR #14670:
URL: https://github.com/apache/kafka/pull/14670#discussion_r1385617039
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerDelegateCreator.java:
##
@@ -0,0 +1,114 @@
+/*
+ * Licensed to the Apache Software Foundat
divijvaidya commented on PR #14629:
URL: https://github.com/apache/kafka/pull/14629#issuecomment-1800218167
Hey @jolshan - You might already know this but sharing in case you don't. A
tool I use to quickly find whether a test is flaky is
https://ge.apache.org/scans/tests?search.rootProjectN
kirktrue commented on code in PR #14670:
URL: https://github.com/apache/kafka/pull/14670#discussion_r1385620217
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkThread.java:
##
@@ -247,12 +247,10 @@ private void closeInternal(final Duration tim
kirktrue commented on code in PR #14670:
URL: https://github.com/apache/kafka/pull/14670#discussion_r1385620881
##
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java:
##
@@ -222,42 +214,74 @@ public void cleanup() {
}
}
-@Test
-
[
https://issues.apache.org/jira/browse/KAFKA-15772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783804#comment-17783804
]
Justine Olshan commented on KAFKA-15772:
I have seen this one be a bit flaky as
[
https://issues.apache.org/jira/browse/KAFKA-15700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783800#comment-17783800
]
Justine Olshan edited comment on KAFKA-15700 at 11/7/23 9:46 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-15759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783798#comment-17783798
]
Justine Olshan edited comment on KAFKA-15759 at 11/7/23 9:46 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-15760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783799#comment-17783799
]
Justine Olshan edited comment on KAFKA-15760 at 11/7/23 9:46 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-15699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783807#comment-17783807
]
Justine Olshan commented on KAFKA-15699:
I've seen this on my builds as well:
[
[
https://issues.apache.org/jira/browse/KAFKA-15690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan updated KAFKA-15690:
---
Labels: flaky-test (was: )
> EosIntegrationTest is flaky.
>
>
[
https://issues.apache.org/jira/browse/KAFKA-15690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783810#comment-17783810
]
Justine Olshan commented on KAFKA-15690:
I saw this as well on my build
[https:
kirktrue commented on code in PR #14670:
URL: https://github.com/apache/kafka/pull/14670#discussion_r1385631654
##
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java:
##
@@ -222,42 +214,74 @@ public void cleanup() {
}
}
-@Test
-
kirktrue commented on code in PR #14670:
URL: https://github.com/apache/kafka/pull/14670#discussion_r1385631897
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerDelegate.java:
##
@@ -0,0 +1,36 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF
Justine Olshan created KAFKA-15797:
--
Summary: Flaky test
EosV2UpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosV2[true]
Key: KAFKA-15797
URL: https://issues.apache.org/jira/browse/KAFKA-15797
Pr
Justine Olshan created KAFKA-15798:
--
Summary: Flaky Test
NamedTopologyIntegrationTest.shouldAddAndRemoveNamedTopologiesBeforeStartingAndRouteQueriesToCorrectTopology()
Key: KAFKA-15798
URL: https://issues.apache.
kirktrue commented on PR #14670:
URL: https://github.com/apache/kafka/pull/14670#issuecomment-1800305244
`KafkaConsumerTest` is a test suite that exercised the functionality of the
"existing" `KafkaConsumer` with 100 tests. With this change, the suite was
refactored to allow each of those t
kirktrue commented on code in PR #14670:
URL: https://github.com/apache/kafka/pull/14670#discussion_r1385680899
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerUtils.java:
##
@@ -211,4 +226,17 @@ else if (t instanceof KafkaException)
thr
kirktrue commented on code in PR #14670:
URL: https://github.com/apache/kafka/pull/14670#discussion_r1385682384
##
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java:
##
@@ -222,42 +214,74 @@ public void cleanup() {
}
}
-@Test
-
kirktrue commented on code in PR #14670:
URL: https://github.com/apache/kafka/pull/14670#discussion_r1385683761
##
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java:
##
@@ -721,16 +802,17 @@ public void
verifyNoCoordinatorLookupForManualAssignmentWi
jolshan commented on PR #14629:
URL: https://github.com/apache/kafka/pull/14629#issuecomment-1800331351
Thanks @divijvaidya. I was taking a look at Gradle enterprise as well. But
the link is helpful
--
This is an automated message from the Apache Git Service.
To respond to the message, pl
jolshan merged PR #14629:
URL: https://github.com/apache/kafka/pull/14629
--
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: jira-unsubscr...@kafka.apache.
jolshan opened a new pull request, #14712:
URL: https://github.com/apache/kafka/pull/14712
With the new callback mechanism we were accidentally passing context with
the wrong request local. Now include a RequestLocal as an explicit argument to
the callback.
Also make the arguments pa
jolshan opened a new pull request, #14713:
URL: https://github.com/apache/kafka/pull/14713
TestUtils.createTopicWithAdmin calls waitForAllPartitionsMetadata which
waits for partition(s) to be present in each brokers' metadata cache. This is a
sufficient check in ZK mode because the controll
1 - 100 of 120 matches
Mail list logo
