chirag-wadhwa5 commented on code in PR #16456:
URL: https://github.com/apache/kafka/pull/16456#discussion_r1675361989
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -3955,11 +3948,484 @@ class KafkaApis(val requestChannel: RequestChannel,
}
}
+ /**
+ * H
[
https://issues.apache.org/jira/browse/KAFKA-17124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865316#comment-17865316
]
Federico Valeri commented on KAFKA-17124:
-
I mean, I thought I fixed that flakin
[
https://issues.apache.org/jira/browse/KAFKA-17124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865313#comment-17865313
]
Chia-Ping Tsai commented on KAFKA-17124:
Could you please share the commit to me
[
https://issues.apache.org/jira/browse/KAFKA-17124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865311#comment-17865311
]
Federico Valeri commented on KAFKA-17124:
-
[~chia7712] I thought I fixed that. A
chia7712 commented on PR #16529:
URL: https://github.com/apache/kafka/pull/16529#issuecomment-2224616092
@ocadaruma thanks for this improvement!
--
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 th
chia7712 merged PR #16529:
URL: https://github.com/apache/kafka/pull/16529
--
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
[
https://issues.apache.org/jira/browse/KAFKA-17061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-17061.
Fix Version/s: 3.9.0
Resolution: Fixed
> KafkaController takes long time to connect
Chia-Ping Tsai created KAFKA-17124:
--
Summary: Fix flaky
DumpLogSegmentsTest#testDumpRemoteLogMetadataNonZeroStartingOffset
Key: KAFKA-17124
URL: https://issues.apache.org/jira/browse/KAFKA-17124
Proj
chia7712 commented on code in PR #16499:
URL: https://github.com/apache/kafka/pull/16499#discussion_r1675284548
##
core/src/test/java/kafka/test/junit/ClusterTestExtensions.java:
##
@@ -119,7 +124,27 @@ public Stream
provideTestTemplateInvocationContex
return generated
m1a2st commented on PR #16557:
URL: https://github.com/apache/kafka/pull/16557#issuecomment-2224534471
@chia7712, Thanks for reminder, rebased it
--
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 t
chia7712 commented on code in PR #16127:
URL: https://github.com/apache/kafka/pull/16127#discussion_r1675282098
##
clients/src/test/java/org/apache/kafka/test/TestUtils.java:
##
@@ -706,4 +706,9 @@ public static ApiVersionsResponse createApiVersionsResponse(
Api
chia7712 commented on PR #16557:
URL: https://github.com/apache/kafka/pull/16557#issuecomment-2224529187
@m1a2st please rebase code to include your recent fix to trigger QA
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
chia7712 commented on PR #16559:
URL: https://github.com/apache/kafka/pull/16559#issuecomment-2224474099
@gongxuanzhang Could you test this patch on your local and then attach the
result?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
chia7712 commented on code in PR #16560:
URL: https://github.com/apache/kafka/pull/16560#discussion_r1675083256
##
tests/README.md:
##
@@ -47,6 +47,10 @@
TC_PATHS="tests/kafkatest/tests/streams/streams_upgrade_test.py::StreamsUpgradeT
```
bash tests/docker/ducker-ak up -j 'op
masonyc commented on code in PR #16563:
URL: https://github.com/apache/kafka/pull/16563#discussion_r1675023567
##
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientTest.java:
##
@@ -281,15 +281,20 @@ public void testGrantVotesWhenShuttingDown(boolean
withKip853Rpc) throws
masonyc commented on code in PR #16563:
URL: https://github.com/apache/kafka/pull/16563#discussion_r1675024064
##
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientSnapshotTest.java:
##
@@ -1977,12 +1978,20 @@ private static ReplicaKey replicaKey(int id, boolean
withDirec
masonyc commented on code in PR #16563:
URL: https://github.com/apache/kafka/pull/16563#discussion_r1675023791
##
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientTest.java:
##
@@ -3860,12 +3865,11 @@ private static ReplicaKey replicaKey(int id, boolean
withDirectoryId)
gongxuanzhang commented on PR #16560:
URL: https://github.com/apache/kafka/pull/16560#issuecomment-2224264080
@chia7712 thanks for your review,I update it
--
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
gongxuanzhang commented on PR #16559:
URL: https://github.com/apache/kafka/pull/16559#issuecomment-2224263676
@chia7712 thanks for your review,I update it
--
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
[
https://issues.apache.org/jira/browse/KAFKA-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-10356.
-
Resolution: Not A Problem
> Handle accidental deletion of sink-topics as exceptional fai
[
https://issues.apache.org/jira/browse/KAFKA-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865263#comment-17865263
]
Matthias J. Sax commented on KAFKA-10356:
-
Talked to a few people, and there was
kirktrue commented on code in PR #16543:
URL: https://github.com/apache/kafka/pull/16543#discussion_r1674890318
##
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java:
##
@@ -720,6 +721,12 @@ private void maybeOverrideEnableAutoCommit(Map configs) {
zzzk1 opened a new pull request, #16576:
URL: https://github.com/apache/kafka/pull/16576
As described from
[KAFKA-16765](https://issues.apache.org/jira/browse/KAFKA-16765):
There may be channel in `newChannels` that are not closed in time
(NioEchoServer#run can handle it, but the process
[
https://issues.apache.org/jira/browse/KAFKA-17097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865251#comment-17865251
]
PoAn Yang commented on KAFKA-17097:
---
PR: https://github.com/apache/kafka/pull/16571
>
FrankYang0529 commented on PR #16566:
URL: https://github.com/apache/kafka/pull/16566#issuecomment-2224098005
> @FrankYang0529 please rebase code to trigger KafkaConsuemrTest
Rebased it. Thank you.
--
This is an automated message from the Apache Git Service.
To respond to the messag
chia7712 commented on code in PR #16540:
URL: https://github.com/apache/kafka/pull/16540#discussion_r1674724394
##
core/src/main/scala/kafka/server/KafkaConfig.scala:
##
@@ -308,7 +308,9 @@ class KafkaConfig private(doLog: Boolean, val props:
util.Map[_, _])
val brokerIdGene
chia7712 commented on code in PR #16558:
URL: https://github.com/apache/kafka/pull/16558#discussion_r1674721981
##
core/src/test/scala/unit/kafka/log/LogValidatorTest.scala:
##
@@ -687,6 +687,57 @@ class LogValidatorTest {
verifyRecordValidationStats(validatedResults.record
chia7712 commented on code in PR #16559:
URL: https://github.com/apache/kafka/pull/16559#discussion_r1674720250
##
build.gradle:
##
@@ -1211,6 +1211,8 @@ project(':core') {
//By default gradle does not handle test dependencies between the
sub-projects
//This line is t
chia7712 commented on code in PR #16560:
URL: https://github.com/apache/kafka/pull/16560#discussion_r1674716809
##
tests/README.md:
##
@@ -47,6 +47,10 @@
TC_PATHS="tests/kafkatest/tests/streams/streams_upgrade_test.py::StreamsUpgradeT
```
bash tests/docker/ducker-ak up -j 'op
chia7712 commented on PR #16566:
URL: https://github.com/apache/kafka/pull/16566#issuecomment-2223956814
@FrankYang0529 please rebase code to trigger KafkaConsuemrTest
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
chia7712 commented on PR #16564:
URL: https://github.com/apache/kafka/pull/16564#issuecomment-2223956208
@TaiJuWu could you please rebase code to check the hangings ?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/KAFKA-17092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-17092.
Fix Version/s: 3.9.0
Resolution: Fixed
> Revisit `KafkaConsumerTest#testBeginningOf
chia7712 merged PR #16541:
URL: https://github.com/apache/kafka/pull/16541
--
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
chia7712 commented on code in PR #16529:
URL: https://github.com/apache/kafka/pull/16529#discussion_r1674687739
##
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/controller/ControllerContextBenchmark.java:
##
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the Apache Software Foundation
C0urante commented on PR #16567:
URL: https://github.com/apache/kafka/pull/16567#issuecomment-2223928868
@showuon would you have a moment to take a look at this one? I believe it's
been the culprit for most of the failures in the Connect
`OffsetsApiIntegrationTest` suite and I'm hoping to i
chia7712 commented on code in PR #14628:
URL: https://github.com/apache/kafka/pull/14628#discussion_r1674672583
##
core/src/main/scala/kafka/tools/StorageTool.scala:
##
@@ -60,7 +63,11 @@ object StorageTool extends Logging {
if (!metadataVersion.isKRaftSupported) {
[
https://issues.apache.org/jira/browse/KAFKA-16855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865217#comment-17865217
]
Muralidhar Basani commented on KAFKA-16855:
---
[~christo_lolov] can you pls prov
[
https://issues.apache.org/jira/browse/KAFKA-17098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865210#comment-17865210
]
Eduwer Camacaro commented on KAFKA-17098:
-
Yes it works! thanks!
> Error Openin
ijuma commented on code in PR #14628:
URL: https://github.com/apache/kafka/pull/14628#discussion_r1674625790
##
core/src/main/scala/kafka/tools/StorageTool.scala:
##
@@ -60,7 +63,11 @@ object StorageTool extends Logging {
if (!metadataVersion.isKRaftSupported) {
[
https://issues.apache.org/jira/browse/KAFKA-17105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton reassigned KAFKA-17105:
-
Assignee: Chris Egerton
> Unnecessary connector restarts after being newly created
> --
[
https://issues.apache.org/jira/browse/KAFKA-14710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-14710.
Resolution: Won't Fix
> KRaft cannot initialise storage for valid UUID
> -
[
https://issues.apache.org/jira/browse/KAFKA-14710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865204#comment-17865204
]
Chia-Ping Tsai commented on KAFKA-14710:
The uuid check was remove by https://gi
[
https://issues.apache.org/jira/browse/KAFKA-17118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-17118:
--
Assignee: kangning.li (was: Chia-Ping Tsai)
> Remove StorageTool#buildMetadataProper
subhashiyer9 commented on code in PR #16496:
URL: https://github.com/apache/kafka/pull/16496#discussion_r1674584267
##
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java:
##
@@ -1201,13 +1201,26 @@ private ClusterAndWaitTime waitOnMetadata(String topic,
chia7712 commented on code in PR #14628:
URL: https://github.com/apache/kafka/pull/14628#discussion_r1674554451
##
core/src/main/scala/kafka/tools/StorageTool.scala:
##
@@ -60,7 +63,11 @@ object StorageTool extends Logging {
if (!metadataVersion.isKRaftSupported) {
Chia-Ping Tsai created KAFKA-17123:
--
Summary: update docs of Storage Tool to clarify that "cluster id"
can be non-uuid format after 3.7
Key: KAFKA-17123
URL: https://issues.apache.org/jira/browse/KAFKA-17123
Chia-Ping Tsai created KAFKA-17122:
--
Summary: Change the type of `clusterId` from `UUID` to `String`
Key: KAFKA-17122
URL: https://issues.apache.org/jira/browse/KAFKA-17122
Project: Kafka
Is
chia7712 commented on code in PR #14628:
URL: https://github.com/apache/kafka/pull/14628#discussion_r1674554451
##
core/src/main/scala/kafka/tools/StorageTool.scala:
##
@@ -60,7 +63,11 @@ object StorageTool extends Logging {
if (!metadataVersion.isKRaftSupported) {
[
https://issues.apache.org/jira/browse/KAFKA-16221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865193#comment-17865193
]
sabeywic commented on KAFKA-16221:
--
Im still facing this issue in version 3.7. Do you g
[
https://issues.apache.org/jira/browse/KAFKA-16855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865191#comment-17865191
]
Muralidhar Basani commented on KAFKA-16855:
---
[~showuon] sure. Will start looki
lzyLuke opened a new pull request, #16575:
URL: https://github.com/apache/kafka/pull/16575
We are seeing ducktape tests failure on upgrade tests.
The thing is some tests should not w
gharris1727 closed pull request #16568: KAFKA-17111: Revert "KAFKA-15996:
Improve JsonConverter performance (#14992)"
URL: https://github.com/apache/kafka/pull/16568
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
apoorvmittal10 opened a new pull request, #16574:
URL: https://github.com/apache/kafka/pull/16574
Added handling of share group heartbeat and describe in KafkaApis. The
Implementation of heartbeat and describe is with group coordinator.
### Committer Checklist (excluded from commit me
jolshan merged PR #16462:
URL: https://github.com/apache/kafka/pull/16462
--
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.
jsancio commented on code in PR #16230:
URL: https://github.com/apache/kafka/pull/16230#discussion_r1674397738
##
clients/src/main/java/org/apache/kafka/common/requests/ApiVersionsResponse.java:
##
@@ -313,10 +313,12 @@ private static FinalizedFeatureKeyCollection
createFinaliz
jolshan commented on PR #16462:
URL: https://github.com/apache/kafka/pull/16462#issuecomment-2223500451
Finally got to confirming the test results 👍 All passed. will merge now.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
jsancio commented on code in PR #16563:
URL: https://github.com/apache/kafka/pull/16563#discussion_r1674382183
##
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientTest.java:
##
@@ -281,15 +281,20 @@ public void testGrantVotesWhenShuttingDown(boolean
withKip853Rpc) throws
[
https://issues.apache.org/jira/browse/KAFKA-16937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865164#comment-17865164
]
Greg Harris commented on KAFKA-16937:
-
I thought about this some more. Right now the
[
https://issues.apache.org/jira/browse/KAFKA-16937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865164#comment-17865164
]
Greg Harris edited comment on KAFKA-16937 at 7/11/24 5:15 PM:
lianetm commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1674318250
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -447,7 +505,8 @@ private ConsumerGroupHeartbeatRequest
get
[
https://issues.apache.org/jira/browse/KAFKA-9738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-9738:
---
Description:
The method {{forwarded()}} to capture the forwarded records in
{{MockProcessorC
[
https://issues.apache.org/jira/browse/KAFKA-9738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-9738:
---
Labels: kip (was: )
> Add Generics Type Parameters to forwarded() in MockProcessorContext
>
jolshan commented on code in PR #16496:
URL: https://github.com/apache/kafka/pull/16496#discussion_r1674314203
##
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java:
##
@@ -1201,13 +1201,26 @@ private ClusterAndWaitTime waitOnMetadata(String topic,
Integ
jolshan commented on code in PR #16183:
URL: https://github.com/apache/kafka/pull/16183#discussion_r1674310171
##
server-common/src/main/java/org/apache/kafka/server/common/MetadataVersion.java:
##
@@ -217,8 +217,11 @@ public enum MetadataVersion {
// Add ELR related suppor
lianetm commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1674309494
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -425,6 +482,7 @@ topicId, mkSortedSet(0)
assertEqu
[
https://issues.apache.org/jira/browse/KAFKA-9738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-9738:
--
Assignee: Matthias J. Sax
> Add Generics Type Parameters to forwarded() in MockProcess
[
https://issues.apache.org/jira/browse/KAFKA-9738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865145#comment-17865145
]
Matthias J. Sax commented on KAFKA-9738:
Given that `Processor` is deprecated alr
[
https://issues.apache.org/jira/browse/KAFKA-10814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-10814.
-
Resolution: Incomplete
Unclear what the problem is. Closing.
> improving ability of han
junrao commented on code in PR #16183:
URL: https://github.com/apache/kafka/pull/16183#discussion_r1674294082
##
server-common/src/main/java/org/apache/kafka/server/common/MetadataVersion.java:
##
@@ -217,8 +217,11 @@ public enum MetadataVersion {
// Add ELR related support
apoorvmittal10 opened a new pull request, #16573:
URL: https://github.com/apache/kafka/pull/16573
ShareGroupHeartbeat API support as defined in KIP-932. The heartbeat
persists Group and Member information on `__consumer_offsets` topic.
The PR also moves some of the ShareGroupConfigs t
dongjinleekr opened a new pull request, #16572:
URL: https://github.com/apache/kafka/pull/16572
### Summary
If the user runs `ReplicaVerificationTool`, it shows a deprecation warning.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementatio
jlprat commented on PR #16570:
URL: https://github.com/apache/kafka/pull/16570#issuecomment-2223290582
Cherry picked 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 commen
[
https://issues.apache.org/jira/browse/KAFKA-17101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865138#comment-17865138
]
Greg Harris commented on KAFKA-17101:
-
Also you mentioned MM1, is that a typo or are
[
https://issues.apache.org/jira/browse/KAFKA-17101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865137#comment-17865137
]
Greg Harris commented on KAFKA-17101:
-
[~kaushik srinivas] Unfortunately I don't see
jlprat commented on PR #16570:
URL: https://github.com/apache/kafka/pull/16570#issuecomment-2223277883
I'll cherry pick this one 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 spe
[
https://issues.apache.org/jira/browse/KAFKA-17101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864935#comment-17864935
]
Greg Harris edited comment on KAFKA-17101 at 7/11/24 3:40 PM:
mjsax commented on PR #16570:
URL: https://github.com/apache/kafka/pull/16570#issuecomment-2223275885
Who is cherry-picking this to `trunk`? @jlprat are you doing this, or should
we (@cadonna) do the cherry-pick?
--
This is an automated message from the Apache Git Service.
To respond to t
[
https://issues.apache.org/jira/browse/KAFKA-17117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865134#comment-17865134
]
Greg Harris commented on KAFKA-17117:
-
Considering that the only plugins typically o
[
https://issues.apache.org/jira/browse/KAFKA-17098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Josep Prat updated KAFKA-17098:
---
Fix Version/s: 3.8.0
> Error Opening RocksDBStore
> --
>
> K
jlprat merged PR #16570:
URL: https://github.com/apache/kafka/pull/16570
--
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-17111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris resolved KAFKA-17111.
-
Resolution: Fixed
> ServiceConfigurationError in JsonSerializer/Deserializer during Plugin
> Di
[
https://issues.apache.org/jira/browse/KAFKA-17119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris resolved KAFKA-17119.
-
Resolution: Cannot Reproduce
> After enabled kafka-ranger-plugin and baned the user for using de
[
https://issues.apache.org/jira/browse/KAFKA-17119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865131#comment-17865131
]
Greg Harris commented on KAFKA-17119:
-
Hi [~StarBoy1005] The Apache Kafka project do
lianetm commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1674210447
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -201,8 +202,42 @@ public void testSuccessfulHeartbeatTiming
lianetm commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1674210447
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -201,8 +202,42 @@ public void testSuccessfulHeartbeatTiming
lianetm commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1674207651
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -201,8 +202,42 @@ public void testSuccessfulHeartbeatTiming
lianetm commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1674174436
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -659,95 +749,50 @@ public void
testPollTimerExpirationShou
lianetm commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1674165119
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -756,18 +801,19 @@ public void
testFencedMemberStopHeartbe
ocadaruma commented on PR #16529:
URL: https://github.com/apache/kafka/pull/16529#issuecomment-2223158388
@chia7712 Added a flamegraph. PTAL
https://issues.apache.org/jira/browse/KAFKA-17061?focusedCommentId=17865110&page=com.atlassian.jira.plugin.system.issuetabpanels%3Acomment-tabpanel#
[
https://issues.apache.org/jira/browse/KAFKA-17061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865110#comment-17865110
]
Haruki Okada commented on KAFKA-17061:
--
Did a micro benchmark to check the performa
[
https://issues.apache.org/jira/browse/KAFKA-17061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haruki Okada updated KAFKA-17061:
-
Description:
h2. Environment
* Kafka version: 3.3.2
* Cluster: 200~ brokers
* Total num parti
[
https://issues.apache.org/jira/browse/KAFKA-17061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haruki Okada updated KAFKA-17061:
-
Attachment: screenshot-flame-patched.png
> KafkaController takes long time to connect to newly a
[
https://issues.apache.org/jira/browse/KAFKA-17061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haruki Okada updated KAFKA-17061:
-
Attachment: screenshot-flame.png
> KafkaController takes long time to connect to newly added bro
lianetm commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1674150218
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -251,23 +304,25 @@ public void testSkippingHeartbeat(final
[
https://issues.apache.org/jira/browse/KAFKA-17061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haruki Okada updated KAFKA-17061:
-
Attachment: flame-patched.html
> KafkaController takes long time to connect to newly added broke
[
https://issues.apache.org/jira/browse/KAFKA-17061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haruki Okada updated KAFKA-17061:
-
Attachment: flame.html
> KafkaController takes long time to connect to newly added broker after
[
https://issues.apache.org/jira/browse/KAFKA-17061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haruki Okada updated KAFKA-17061:
-
Description:
h2. Environment
* Kafka version: 3.3.2
* Cluster: 200~ brokers
* Total num parti
FrankYang0529 commented on code in PR #16449:
URL: https://github.com/apache/kafka/pull/16449#discussion_r1674145282
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -1501,11 +1501,11 @@ public void unsubscribe() {
privat
lianetm commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1674142299
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -201,8 +202,42 @@ public void testSuccessfulHeartbeatTiming
lianetm commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1674138238
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -201,8 +202,42 @@ public void testSuccessfulHeartbeatTiming
1 - 100 of 154 matches
Mail list logo
