showuon opened a new pull request, #15077:
URL: https://github.com/apache/kafka/pull/15077
Following @dajac 's finding in https://github.com/apache/kafka/pull/15063, I
found we also create new RemoteLogManager in ReplicaManagerTest, but didn't
close them.
While investigating Replica
showuon commented on PR #15077:
URL: https://github.com/apache/kafka/pull/15077#issuecomment-1870075510
@dajac @jolshan @satishd , call for review. 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 above
divijvaidya commented on code in PR #15077:
URL: https://github.com/apache/kafka/pull/15077#discussion_r1436885274
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -2693,6 +2693,9 @@ class ReplicaManagerTest {
} else {
assertTrue(stray0.isInst
divijvaidya commented on PR #14798:
URL: https://github.com/apache/kafka/pull/14798#issuecomment-1870137596
@ijuma may I ask another review since I changed to a newer version since
your last approval.
--
This is an automated message from the Apache Git Service.
To respond to the message,
akaltsikis opened a new pull request, #15078:
URL: https://github.com/apache/kafka/pull/15078
KAFKA-16047: Leverage the fenceProducers timeout in the InitProducerId
This is expected to respect the timeout that fenceProducers have, in the
InitProducerId request.
### Committe
[
https://issues.apache.org/jira/browse/KAFKA-16047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800731#comment-17800731
]
Angelos Kaltsikis commented on KAFKA-16047:
---
Hey [~gharris1727], here is the M
divijvaidya commented on PR #15071:
URL: https://github.com/apache/kafka/pull/15071#issuecomment-1870147486
@ijuma requesting your review on this cleanup as well please.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
divijvaidya commented on code in PR #15072:
URL: https://github.com/apache/kafka/pull/15072#discussion_r1436914220
##
clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java:
##
@@ -479,7 +479,7 @@ private static class NodeConnectionState {
private f
divijvaidya commented on PR #15072:
URL: https://github.com/apache/kafka/pull/15072#issuecomment-1870156605
Checkstyle doesn't have a rule [1] available to enforce that fields which
are not changing are marked as final. Hence, I am not changing anything in the
checkstyle here in this PR.
showuon commented on code in PR #15077:
URL: https://github.com/apache/kafka/pull/15077#discussion_r1436972102
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -2693,6 +2693,9 @@ class ReplicaManagerTest {
} else {
assertTrue(stray0.isInstance
satishd commented on code in PR #15077:
URL: https://github.com/apache/kafka/pull/15077#discussion_r1436993064
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -4020,6 +4031,7 @@ class ReplicaManagerTest {
doneLatch.countDown()
} finally {
vamossagar12 commented on PR #15072:
URL: https://github.com/apache/kafka/pull/15072#issuecomment-1870244078
Thanks @divijvaidya , I think Ismael's point is correct. From what I recall,
the streams final rule also expects the method arguements etc to be final as
well (apart from local varia
showuon commented on PR #15077:
URL: https://github.com/apache/kafka/pull/15077#issuecomment-1870263212
@satishd , I've closed all the instances in finally block quietly in this
commit:
https://github.com/apache/kafka/pull/15077/commits/dd913a8668cf773a51403e482cc704b44cb0e8a1
. Thanks.
Divij Vaidya created KAFKA-16052:
Summary: OOM in Kafka test suite
Key: KAFKA-16052
URL: https://issues.apache.org/jira/browse/KAFKA-16052
Project: Kafka
Issue Type: Bug
Affects Versions:
Divij Vaidya created KAFKA-16053:
Summary: Fix leaked Default DirectoryService
Key: KAFKA-16053
URL: https://issues.apache.org/jira/browse/KAFKA-16053
Project: Kafka
Issue Type: Sub-task
divijvaidya opened a new pull request, #15079:
URL: https://github.com/apache/kafka/pull/15079
# Problem
We are facing OOM while running test suite for Apache Kafka as discussed in
https://lists.apache.org/thread/d5js0xpsrsvhgjb10mbzo9cwsy8087x4
# Changes
This JIRA fixes ~2
divijvaidya commented on code in PR #15077:
URL: https://github.com/apache/kafka/pull/15077#discussion_r1437022630
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -2704,28 +2710,30 @@ class ReplicaManagerTest {
time = time,
scheduler = time
showuon commented on code in PR #15077:
URL: https://github.com/apache/kafka/pull/15077#discussion_r1437024347
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -2704,28 +2710,30 @@ class ReplicaManagerTest {
time = time,
scheduler = time.sch
showuon commented on code in PR #15077:
URL: https://github.com/apache/kafka/pull/15077#discussion_r1437026129
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -2704,28 +2710,30 @@ class ReplicaManagerTest {
time = time,
scheduler = time.sch
[
https://issues.apache.org/jira/browse/KAFKA-16053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-16053:
-
Description:
Heap dump hinted towards a leaked DefaultDirectoryService while running
:core:test
[
https://issues.apache.org/jira/browse/KAFKA-16053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-16053:
-
Attachment: Screenshot 2023-12-27 at 13.18.33.png
> Fix leaked Default DirectoryService
> --
divijvaidya commented on PR #15079:
URL: https://github.com/apache/kafka/pull/15079#issuecomment-1870288475
@dajac @ableegoldman please review. This is not the root cause of our recent
OOM errors but is a contributor to it.
(cc: @stanislavkozlovski as a potential backport to 3.7)
--
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-16052:
-
Attachment: Screenshot 2023-12-27 at 14.04.52.png
> OOM in Kafka test suite
> --
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800764#comment-17800764
]
Divij Vaidya commented on KAFKA-16052:
--
The tests are still running but as of now t
divijvaidya commented on code in PR #15077:
URL: https://github.com/apache/kafka/pull/15077#discussion_r1437034332
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -2704,28 +2710,30 @@ class ReplicaManagerTest {
time = time,
scheduler = time
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-16052:
-
Attachment: Screenshot 2023-12-27 at 14.22.21.png
> OOM in Kafka test suite
> --
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-16052:
-
Description:
Our test suite is failing with frequent OOM. Discussion in the mailing list is
her
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-16052:
-
Description:
Our test suite is failing with frequent OOM. Discussion in the mailing list is
her
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-16052:
-
Description:
Our test suite is failing with frequent OOM. Discussion in the mailing list is
her
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-16052:
-
Description:
Our test suite is failing with frequent OOM. Discussion in the mailing list is
her
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-16052:
-
Description:
*Problem*
Our test suite is failing with frequent OOM. Discussion in the mailing li
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-16052:
-
Attachment: Screenshot 2023-12-27 at 14.45.20.png
> OOM in Kafka test suite
> --
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800770#comment-17800770
]
Divij Vaidya commented on KAFKA-16052:
--
We have a org.mockito.internal.verification
Oleksandr Shulgin created KAFKA-16054:
-
Summary: Sudden 100% CPU on a broker
Key: KAFKA-16054
URL: https://issues.apache.org/jira/browse/KAFKA-16054
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800772#comment-17800772
]
Divij Vaidya commented on KAFKA-16052:
--
Let's try to find the test which was runnin
[
https://issues.apache.org/jira/browse/KAFKA-16054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleksandr Shulgin updated KAFKA-16054:
--
Description:
We have observed now for the 3rd time in production the issue where a Kaf
[
https://issues.apache.org/jira/browse/KAFKA-16054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleksandr Shulgin updated KAFKA-16054:
--
Description:
We have observed now for the 3rd time in production the issue where a Kaf
[
https://issues.apache.org/jira/browse/KAFKA-16054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleksandr Shulgin updated KAFKA-16054:
--
Description:
We have observed now for the 3rd time in production the issue where a Kaf
[
https://issues.apache.org/jira/browse/KAFKA-16054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleksandr Shulgin updated KAFKA-16054:
--
Description:
We have observed now for the 3rd time in production the issue where a Kaf
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800772#comment-17800772
]
Divij Vaidya edited comment on KAFKA-16052 at 12/27/23 2:01 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-16052:
-
Attachment: Screenshot 2023-12-27 at 15.31.09.png
> OOM in Kafka test suite
> --
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800788#comment-17800788
]
Divij Vaidya commented on KAFKA-16052:
--
ok, I might have found the offending test.
[
https://issues.apache.org/jira/browse/KAFKA-15904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Proven Provenzano updated KAFKA-15904:
--
Fix Version/s: 3.7.0
(was: 3.8.0)
> Downgrade tests are failing
[
https://issues.apache.org/jira/browse/KAFKA-15904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Proven Provenzano resolved KAFKA-15904.
---
Resolution: Fixed
This was merged into trunk a month ago, long before the 3.7 branch
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800797#comment-17800797
]
Divij Vaidya commented on KAFKA-16052:
--
I am now running a single threaded test exe
developster opened a new pull request, #15080:
URL: https://github.com/apache/kafka/pull/15080
*Description of the change*
Changed StandaloneHerder to always synchronize on itself before invoking any
methods on MemoryConfigBackingStore. This helped the situation as the order of
acquiring
[
https://issues.apache.org/jira/browse/KAFKA-16051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800814#comment-17800814
]
Octavian Ciubotaru commented on KAFKA-16051:
Hi [~gharris1727] , Thank you f
[
https://issues.apache.org/jira/browse/KAFKA-16051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800815#comment-17800815
]
Octavian Ciubotaru commented on KAFKA-16051:
I do not have the privileges to
[
https://issues.apache.org/jira/browse/KAFKA-15495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ron Dagostino updated KAFKA-15495:
--
Summary: Partition truncated when the only ISR member restarts with an
empty disk (was: KRaft
[
https://issues.apache.org/jira/browse/KAFKA-15495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ron Dagostino updated KAFKA-15495:
--
Affects Version/s: 3.6.1
3.5.2
3.5.0
[
https://issues.apache.org/jira/browse/KAFKA-15495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ron Dagostino updated KAFKA-15495:
--
Affects Version/s: 3.2.1
3.1.2
3.0.2
[
https://issues.apache.org/jira/browse/KAFKA-15495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ron Dagostino updated KAFKA-15495:
--
Affects Version/s: 2.7.2
2.6.3
3.1.0
[
https://issues.apache.org/jira/browse/KAFKA-15495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ron Dagostino updated KAFKA-15495:
--
Affects Version/s: 2.2.1
2.3.0
2.1.1
[
https://issues.apache.org/jira/browse/KAFKA-15495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ron Dagostino updated KAFKA-15495:
--
Description:
Assume a topic-partition has just a single leader replica in the ISR. Assume
ne
[
https://issues.apache.org/jira/browse/KAFKA-16044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Afshin Moazami reassigned KAFKA-16044:
--
Assignee: Afshin Moazami
> Throttling using Topic Partition Quota
>
[
https://issues.apache.org/jira/browse/KAFKA-16043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Afshin Moazami reassigned KAFKA-16043:
--
Assignee: Afshin Moazami
> Add Quota configuration for topics
> -
sciclon2 commented on code in PR #15030:
URL: https://github.com/apache/kafka/pull/15030#discussion_r1437137364
##
tools/src/main/java/org/apache/kafka/tools/LeaderElectionCommand.java:
##
@@ -99,8 +99,12 @@ static void run(Duration timeoutMs, String... args) throws
Exception {
sciclon2 commented on code in PR #15030:
URL: https://github.com/apache/kafka/pull/15030#discussion_r1437137364
##
tools/src/main/java/org/apache/kafka/tools/LeaderElectionCommand.java:
##
@@ -99,8 +99,12 @@ static void run(Duration timeoutMs, String... args) throws
Exception {
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-16052:
-
Attachment: Screenshot 2023-12-27 at 17.44.09.png
> OOM in Kafka test suite
> --
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800828#comment-17800828
]
Divij Vaidya commented on KAFKA-16052:
--
Digging into the new heap dump after disabl
jolshan commented on code in PR #15077:
URL: https://github.com/apache/kafka/pull/15077#discussion_r1437157116
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -2639,59 +2639,65 @@ class ReplicaManagerTest {
time = time,
scheduler = time.sch
[
https://issues.apache.org/jira/browse/KAFKA-15147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800832#comment-17800832
]
Christo Lolov commented on KAFKA-15147:
---
Heya [~enether]! I believe all the work t
[
https://issues.apache.org/jira/browse/KAFKA-14132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800833#comment-17800833
]
Christo Lolov commented on KAFKA-14132:
---
Heya [~enether], thanks for checking in o
[
https://issues.apache.org/jira/browse/KAFKA-15495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800845#comment-17800845
]
Ron Dagostino commented on KAFKA-15495:
---
Thanks, [~jsancio]. I've updated the tit
gharris1727 commented on code in PR #15078:
URL: https://github.com/apache/kafka/pull/15078#discussion_r1437200184
##
clients/src/main/java/org/apache/kafka/clients/admin/internals/FenceProducersHandler.java:
##
@@ -82,9 +86,10 @@ InitProducerIdRequest.Builder buildSingleRequest
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800851#comment-17800851
]
Justine Olshan commented on KAFKA-16052:
Thanks Divij for the digging. These tes
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800852#comment-17800852
]
Justine Olshan commented on KAFKA-16052:
I can also take a look at the heap dump
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800853#comment-17800853
]
Divij Vaidya commented on KAFKA-16052:
--
Yes Justine, that is my current line of tho
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800855#comment-17800855
]
Justine Olshan commented on KAFKA-16052:
Doing a quick scan at the InterceptedIn
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800855#comment-17800855
]
Justine Olshan edited comment on KAFKA-16052 at 12/27/23 7:19 PM:
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800855#comment-17800855
]
Justine Olshan edited comment on KAFKA-16052 at 12/27/23 7:20 PM:
[
https://issues.apache.org/jira/browse/KAFKA-16045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur reassigned KAFKA-16045:
Assignee: David Arthur
> ZkMigrationIntegrationTest.testMigrateTopicDeletion flaky
>
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800865#comment-17800865
]
Justine Olshan commented on KAFKA-16052:
Taking a look at removing the mock as w
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800874#comment-17800874
]
Ismael Juma commented on KAFKA-16052:
-
Have you tried clearing the mocks during tear
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800875#comment-17800875
]
Ismael Juma commented on KAFKA-16052:
-
It can be done via Mockito.framework().clearI
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800877#comment-17800877
]
Justine Olshan commented on KAFKA-16052:
Ah – good point [~ijuma]. I will look i
jolshan opened a new pull request, #15081:
URL: https://github.com/apache/kafka/pull/15081
(no comment)
--
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-ma
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800880#comment-17800880
]
Justine Olshan commented on KAFKA-16052:
There are only four tests in the group
mumrah opened a new pull request, #15082:
URL: https://github.com/apache/kafka/pull/15082
(no comment)
--
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-mai
jolshan commented on PR #15066:
URL: https://github.com/apache/kafka/pull/15066#issuecomment-1870661247
@afshing -- can you link the commit that moved the code in your description?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitH
Kohei Nozaki created KAFKA-16055:
Summary: Thread unsafe use of HashMap stored in
QueryableStoreProvider#storeProviders
Key: KAFKA-16055
URL: https://issues.apache.org/jira/browse/KAFKA-16055
Project:
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-16052:
-
Attachment: Screenshot 2023-12-28 at 00.13.06.png
> OOM in Kafka test suite
> --
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800892#comment-17800892
]
Divij Vaidya commented on KAFKA-16052:
--
I don't think that clearing the mocks is he
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800892#comment-17800892
]
Divij Vaidya edited comment on KAFKA-16052 at 12/27/23 11:19 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-16052:
-
Attachment: Screenshot 2023-12-28 at 00.18.56.png
> OOM in Kafka test suite
> --
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800893#comment-17800893
]
Divij Vaidya commented on KAFKA-16052:
--
Also, when we look at what is inside the In
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800893#comment-17800893
]
Divij Vaidya edited comment on KAFKA-16052 at 12/27/23 11:23 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-15997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800900#comment-17800900
]
Ritika Reddy commented on KAFKA-15997:
--
Hey, from what I understand you are trying
[
https://issues.apache.org/jira/browse/KAFKA-15997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800900#comment-17800900
]
Ritika Reddy edited comment on KAFKA-15997 at 12/28/23 1:39 AM:
--
[
https://issues.apache.org/jira/browse/KAFKA-15997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800901#comment-17800901
]
Ritika Reddy commented on KAFKA-15997:
--
In case of the first assignment, I have wri
[
https://issues.apache.org/jira/browse/KAFKA-15997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800900#comment-17800900
]
Ritika Reddy edited comment on KAFKA-15997 at 12/28/23 1:41 AM:
--
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800902#comment-17800902
]
Justine Olshan commented on KAFKA-16052:
Thanks Divij. This might be a few thing
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800903#comment-17800903
]
Justine Olshan commented on KAFKA-16052:
It looks like the method that is actual
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800903#comment-17800903
]
Justine Olshan edited comment on KAFKA-16052 at 12/28/23 2:05 AM:
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800909#comment-17800909
]
Justine Olshan commented on KAFKA-16052:
So I realized that every test runs thou
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800909#comment-17800909
]
Justine Olshan edited comment on KAFKA-16052 at 12/28/23 2:35 AM:
satishd commented on code in PR #15077:
URL: https://github.com/apache/kafka/pull/15077#discussion_r1437341409
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -2704,28 +2710,30 @@ class ReplicaManagerTest {
time = time,
scheduler = time.sch
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800911#comment-17800911
]
Justine Olshan commented on KAFKA-16052:
What do we think about lowering the num
satishd commented on code in PR #15077:
URL: https://github.com/apache/kafka/pull/15077#discussion_r1437344252
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -167,7 +167,7 @@ class ReplicaManagerTest {
.foreach(checkpointFile => assertTrue(File
showuon commented on code in PR #15077:
URL: https://github.com/apache/kafka/pull/15077#discussion_r1437350213
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -2639,59 +2639,65 @@ class ReplicaManagerTest {
time = time,
scheduler = time.sch
1 - 100 of 108 matches
Mail list logo
