chia7712 commented on PR #19462:
URL: https://github.com/apache/kafka/pull/19462#issuecomment-2817822197
@kamalcph the new test `testPendingTaskSize` could be hanging (see
https://github.com/apache/kafka/actions/runs/14560322254/job/40842877645?pr=19521),
and I have opened https://issues.ap
chia7712 commented on PR #19521:
URL: https://github.com/apache/kafka/pull/19521#issuecomment-2817819997
the hanging test is traced by
https://issues.apache.org/jira/browse/KAFKA-19180
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
Chia-Ping Tsai created KAFKA-19180:
--
Summary: Fix the hanging testPendingTaskSize
Key: KAFKA-19180
URL: https://issues.apache.org/jira/browse/KAFKA-19180
Project: Kafka
Issue Type: Improveme
[
https://issues.apache.org/jira/browse/KAFKA-19180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17946065#comment-17946065
]
Chia-Ping Tsai commented on KAFKA-19180:
the check of `assertEquals(2, scheduler
chia7712 merged PR #19521:
URL: https://github.com/apache/kafka/pull/19521
--
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 #19525:
URL: https://github.com/apache/kafka/pull/19525#discussion_r2052080927
##
.github/scripts/junit.py:
##
@@ -361,7 +361,7 @@ def split_report_path(base_path: str, report_path: str) ->
Tuple[str, str]:
failure_messages.append(f"Gra
chia7712 commented on PR #19482:
URL: https://github.com/apache/kafka/pull/19482#issuecomment-2817853834
the timeout is traced by https://issues.apache.org/jira/browse/KAFKA-19180
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
[
https://issues.apache.org/jira/browse/KAFKA-19180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17946067#comment-17946067
]
Jhen-Yung Hsu commented on KAFKA-19180:
---
I'm working on this, thanks :)
> Fix the
[
https://issues.apache.org/jira/browse/KAFKA-19180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jhen-Yung Hsu reassigned KAFKA-19180:
-
Assignee: Jhen-Yung Hsu (was: Chia-Ping Tsai)
> Fix the hanging testPendingTaskSize
>
Yunyung opened a new pull request, #19526:
URL: https://github.com/apache/kafka/pull/19526
Jira: https://issues.apache.org/jira/browse/KAFKA-19180
--
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
FrankYang0529 commented on code in PR #19525:
URL: https://github.com/apache/kafka/pull/19525#discussion_r2052129769
##
.github/scripts/junit.py:
##
@@ -361,7 +361,7 @@ def split_report_path(base_path: str, report_path: str) ->
Tuple[str, str]:
failure_messages.append(
chia7712 commented on code in PR #19526:
URL: https://github.com/apache/kafka/pull/19526#discussion_r2052123890
##
core/src/test/scala/unit/kafka/utils/SchedulerTest.scala:
##
@@ -220,7 +220,9 @@ class SchedulerTest {
scheduler.scheduleOnce("task1", task1, 0)
scheduler
m1a2st commented on PR #19520:
URL: https://github.com/apache/kafka/pull/19520#issuecomment-2819822694
Thanks for @FrankYang0529 comments, addressed all.
--
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
github-actions[bot] commented on PR #9937:
URL: https://github.com/apache/kafka/pull/9937#issuecomment-2819983618
This PR has been closed since it has not had any activity in 120 days. If
you feel like this
was a mistake, or you would like to continue working on it, please feel free
to r
github-actions[bot] closed pull request #9937: KAFKA-4759 Add support for IPv4
and IPv6 ranges in AclAuthorizer
URL: https://github.com/apache/kafka/pull/9937
--
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
github-actions[bot] commented on PR #17896:
URL: https://github.com/apache/kafka/pull/17896#issuecomment-2819983767
This PR has been closed since it has not had any activity in 120 days. If
you feel like this
was a mistake, or you would like to continue working on it, please feel free
to
github-actions[bot] closed pull request #17896: KAFKA-18046: cache calls to
LoggerFactory.getLogger() inside LogContext
URL: https://github.com/apache/kafka/pull/17896
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
U
frankvicky merged PR #19525:
URL: https://github.com/apache/kafka/pull/19525
--
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.apac
RaphaelFakhri opened a new pull request, #19531:
URL: https://github.com/apache/kafka/pull/19531
## Problem
The `kafka.utils.Pool` class is a thin Scala wrapper around
`java.util.concurrent.ConcurrentHashMap`. While it provides a convenient
`getAndMaybePut` method, the underlying fun
frankvicky commented on code in PR #19519:
URL: https://github.com/apache/kafka/pull/19519#discussion_r2053226336
##
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java:
##
@@ -3746,7 +3746,9 @@ private MetricName expectedMetricName(String clientId,
S
m1a2st commented on PR #19393:
URL: https://github.com/apache/kafka/pull/19393#issuecomment-2820100352
Thanks for @chia7712 comments, addressed 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
[
https://issues.apache.org/jira/browse/KAFKA-18322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17946318#comment-17946318
]
Alieh Saeedi commented on KAFKA-18322:
--
PR: https://github.com/apache/kafka/pull/18
github-actions[bot] commented on PR #19468:
URL: https://github.com/apache/kafka/pull/19468#issuecomment-2819963675
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
github-actions[bot] commented on PR #19297:
URL: https://github.com/apache/kafka/pull/19297#issuecomment-2819963775
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
github-actions[bot] commented on PR #19236:
URL: https://github.com/apache/kafka/pull/19236#issuecomment-2819963821
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
github-actions[bot] commented on PR #19231:
URL: https://github.com/apache/kafka/pull/19231#issuecomment-2819963851
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
[
https://issues.apache.org/jira/browse/KAFKA-19131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17946290#comment-17946290
]
PoAn Yang commented on KAFKA-19131:
---
[~ckamal] yes, I'm working on it. I will create a
k-raina opened a new pull request, #15913:
URL: https://github.com/apache/kafka/pull/15913
This is example code template for Transactional Client. This code assumes
that new Exception types have already been implemented.
This PR will be merged after:
https://cwiki.apache.org/confluen
[
https://issues.apache.org/jira/browse/KAFKA-19131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17946182#comment-17946182
]
Kamal Chandraprakash commented on KAFKA-19131:
--
[~yangpoan]
Are you worki
junrao commented on code in PR #19371:
URL: https://github.com/apache/kafka/pull/19371#discussion_r2052715308
##
core/src/main/scala/kafka/raft/KafkaMetadataLog.scala:
##
@@ -585,32 +585,62 @@ object KafkaMetadataLog extends Logging {
config: MetadataLogConfig,
nodeId:
[
https://issues.apache.org/jira/browse/KAFKA-19014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17946185#comment-17946185
]
Kamal Chandraprakash commented on KAFKA-19014:
--
In KAFKA-17184, a 10 second
junrao commented on code in PR #19437:
URL: https://github.com/apache/kafka/pull/19437#discussion_r2052746487
##
core/src/main/java/kafka/server/share/DelayedShareFetch.java:
##
@@ -277,22 +316,32 @@ public boolean tryComplete() {
return false;
} catch (Exc
[
https://issues.apache.org/jira/browse/KAFKA-19014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17946185#comment-17946185
]
Kamal Chandraprakash edited comment on KAFKA-19014 at 4/21/25 5:26 PM:
---
[
https://issues.apache.org/jira/browse/KAFKA-19014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kamal Chandraprakash resolved KAFKA-19014.
--
Fix Version/s: 4.1.0
Assignee: Kamal Chandraprakash
Resolution:
showuon closed pull request #19368: [WIP]: Backport java 24 all2
URL: https://github.com/apache/kafka/pull/19368
--
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,
kamalcph commented on PR #19526:
URL: https://github.com/apache/kafka/pull/19526#issuecomment-2818316925
LGTM, thanks for fixing this test.
--
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-19069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jhen-Yung Hsu reassigned KAFKA-19069:
-
Assignee: Jhen-Yung Hsu (was: Cheng Yi Chang)
> DumpLogSegments does not dump the LEAD
[
https://issues.apache.org/jira/browse/KAFKA-19069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17946164#comment-17946164
]
Jhen-Yung Hsu commented on KAFKA-19069:
---
I'm working on this, thanks :)
> DumpLog
mimaison merged PR #19302:
URL: https://github.com/apache/kafka/pull/19302
--
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
Chirag Wadhwa created KAFKA-19181:
-
Summary: Investigate system test failures
Key: KAFKA-19181
URL: https://issues.apache.org/jira/browse/KAFKA-19181
Project: Kafka
Issue Type: Sub-task
apoorvmittal10 commented on code in PR #19500:
URL: https://github.com/apache/kafka/pull/19500#discussion_r2052300583
##
server/src/main/java/org/apache/kafka/server/share/session/ShareSessionCache.java:
##
@@ -122,15 +113,9 @@ public synchronized ShareSession remove(ShareSessio
apoorvmittal10 commented on code in PR #19500:
URL: https://github.com/apache/kafka/pull/19500#discussion_r2052300583
##
server/src/main/java/org/apache/kafka/server/share/session/ShareSessionCache.java:
##
@@ -122,15 +113,9 @@ public synchronized ShareSession remove(ShareSessio
ahuang98 commented on code in PR #19416:
URL: https://github.com/apache/kafka/pull/19416#discussion_r2052945464
##
raft/src/main/java/org/apache/kafka/raft/internals/KRaftVersionUpgrade.java:
##
@@ -0,0 +1,65 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
apoorvmittal10 commented on code in PR #19500:
URL: https://github.com/apache/kafka/pull/19500#discussion_r2052247183
##
server/src/main/java/org/apache/kafka/server/share/session/ShareSessionCache.java:
##
@@ -122,15 +113,9 @@ public synchronized ShareSession remove(ShareSessio
[
https://issues.apache.org/jira/browse/KAFKA-19183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17946119#comment-17946119
]
Chia-Ping Tsai commented on KAFKA-19183:
It seems to me Pool is unnecessary afte
chia7712 commented on code in PR #19525:
URL: https://github.com/apache/kafka/pull/19525#discussion_r2052355478
##
.github/scripts/junit.py:
##
@@ -361,7 +361,7 @@ def split_report_path(base_path: str, report_path: str) ->
Tuple[str, str]:
failure_messages.append(f"Gra
[
https://issues.apache.org/jira/browse/KAFKA-19183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17946124#comment-17946124
]
PoAn Yang commented on KAFKA-19183:
---
[~chia7712], thanks for the suggestion. I will ch
chirag-wadhwa5 commented on code in PR #19500:
URL: https://github.com/apache/kafka/pull/19500#discussion_r2052372535
##
server/src/main/java/org/apache/kafka/server/share/session/ShareSessionCache.java:
##
@@ -122,15 +113,9 @@ public synchronized ShareSession remove(ShareSessio
[
https://issues.apache.org/jira/browse/KAFKA-19183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
PoAn Yang updated KAFKA-19183:
--
Description:
1. Replace Pool.scala with ConcurrentHashMap directly.
2. Remove PoolTest.scala.
was:
[
https://issues.apache.org/jira/browse/KAFKA-19183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
PoAn Yang updated KAFKA-19183:
--
Summary: Replace Pool with ConcurrentHashMap (was: Move Pool and PoolTest
to server module)
> Replac
frankvicky merged PR #19524:
URL: https://github.com/apache/kafka/pull/19524
--
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.apac
FrankYang0529 commented on PR #19232:
URL: https://github.com/apache/kafka/pull/19232#issuecomment-2818879120
@chia7712, I addressed all comments. Could you review again when you have
time? Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, ple
jolshan commented on code in PR #17022:
URL: https://github.com/apache/kafka/pull/17022#discussion_r2052656744
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -737,14 +737,21 @@ public synchronized void
maybeTransitionToErrorS
ahuang98 commented on code in PR #19416:
URL: https://github.com/apache/kafka/pull/19416#discussion_r2052997970
##
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientReconfigTest.java:
##
@@ -2130,6 +2136,444 @@ void testFollowerSendsUpdateVoter() throws Exception {
frankvicky commented on PR #19525:
URL: https://github.com/apache/kafka/pull/19525#issuecomment-2818419704
@gongxuanzhang: Could you please merge the trunk to include #19526 ?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
chia7712 commented on code in PR #19497:
URL: https://github.com/apache/kafka/pull/19497#discussion_r2052397193
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java:
##
@@ -650,24 +658,18 @@ public int deleteAllOffsets(
// Del
[
https://issues.apache.org/jira/browse/KAFKA-19183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17946134#comment-17946134
]
Ismael Juma commented on KAFKA-19183:
-
The main difference is that `Pool` sets the v
[
https://issues.apache.org/jira/browse/KAFKA-19183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17946135#comment-17946135
]
Ismael Juma commented on KAFKA-19183:
-
Not sure if that's worth having a separate cl
apalan60 commented on PR #19482:
URL: https://github.com/apache/kafka/pull/19482#issuecomment-2818448633
@chia7712
Thanks for the kind reminder, merging the trunk now.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
chia7712 commented on PR #19482:
URL: https://github.com/apache/kafka/pull/19482#issuecomment-2818434084
@apalan60 could you please rebase code?
--
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
[
https://issues.apache.org/jira/browse/KAFKA-19183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17946137#comment-17946137
]
Chia-Ping Tsai commented on KAFKA-19183:
{quote}
Not sure if that's worth having
chia7712 commented on code in PR #19500:
URL: https://github.com/apache/kafka/pull/19500#discussion_r2052293842
##
server/src/main/java/org/apache/kafka/server/share/session/ShareSessionCache.java:
##
@@ -122,15 +113,9 @@ public synchronized ShareSession remove(ShareSession
ses
chia7712 commented on PR #19526:
URL: https://github.com/apache/kafka/pull/19526#issuecomment-2818242350
@kamalcph WDYT? This PR uses a loop to ensure the test passes.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
[
https://issues.apache.org/jira/browse/KAFKA-19180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kamal Chandraprakash resolved KAFKA-19180.
--
Fix Version/s: 4.1.0
Resolution: Fixed
> Fix the hanging testPendingTas
m1a2st opened a new pull request, #19527:
URL: https://github.com/apache/kafka/pull/19527
add KIP-877 support for Login
--
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.
apoorvmittal10 commented on code in PR #19500:
URL: https://github.com/apache/kafka/pull/19500#discussion_r2052543453
##
server/src/main/java/org/apache/kafka/server/share/session/ShareSession.java:
##
@@ -138,6 +118,12 @@ public synchronized Map> up
return result;
[
https://issues.apache.org/jira/browse/KAFKA-18216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17946150#comment-17946150
]
TengYao Chi commented on KAFKA-18216:
-
Hi [~pnee] [~lianetm]
I have tried to repro
José Armando García Sancio created KAFKA-19184:
--
Summary: Document kraft version upgrade
Key: KAFKA-19184
URL: https://issues.apache.org/jira/browse/KAFKA-19184
Project: Kafka
Is
junrao commented on code in PR #19437:
URL: https://github.com/apache/kafka/pull/19437#discussion_r2052697705
##
core/src/main/java/kafka/server/share/DelayedShareFetch.java:
##
@@ -252,13 +291,19 @@ public boolean tryComplete() {
// replicaManager.readFromLog t
jsancio commented on code in PR #19353:
URL: https://github.com/apache/kafka/pull/19353#discussion_r2052833219
##
clients/src/main/java/org/apache/kafka/common/requests/ApiVersionsResponse.java:
##
@@ -152,19 +151,19 @@ public boolean zkMigrationReady() {
return data.zk
apoorvmittal10 commented on code in PR #19505:
URL: https://github.com/apache/kafka/pull/19505#discussion_r2052858046
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupConfigTest.java:
##
@@ -89,24 +87,6 @@ public void testInvalidConfig
jsancio commented on code in PR #19353:
URL: https://github.com/apache/kafka/pull/19353#discussion_r2052834226
##
clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java:
##
@@ -106,189 +107,189 @@ public static AbstractResponse parseResponse(ByteBuffer
buf
apoorvmittal10 commented on code in PR #19430:
URL: https://github.com/apache/kafka/pull/19430#discussion_r2052861184
##
core/src/main/java/kafka/server/share/SharePartition.java:
##
@@ -197,6 +197,16 @@ public byte id() {
}
}
+/**
+ * The DeliveryCountOp
apoorvmittal10 commented on PR #19200:
URL: https://github.com/apache/kafka/pull/19200#issuecomment-2819324703
@dejan2609 Sorry for the delay, I was away for sometime. The PR is on my
pending list for review now.
--
This is an automated message from the Apache Git Service.
To respond to t
mjsax commented on code in PR #14626:
URL: https://github.com/apache/kafka/pull/14626#discussion_r2052898296
##
streams/src/main/java/org/apache/kafka/streams/state/internals/StoreQueryUtils.java:
##
@@ -335,6 +345,28 @@ private static QueryResult
runWindowRangeQuery(final Que
soondenana commented on code in PR #19353:
URL: https://github.com/apache/kafka/pull/19353#discussion_r2052926304
##
clients/src/main/java/org/apache/kafka/common/requests/ApiVersionsResponse.java:
##
@@ -152,19 +151,19 @@ public boolean zkMigrationReady() {
return data
[
https://issues.apache.org/jira/browse/KAFKA-19019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-19019.
-
Fix Version/s: 4.1.0
Resolution: Fixed
merged the PR to trunk
> Verify Share Fetch with Tiered S
junrao merged PR #19437:
URL: https://github.com/apache/kafka/pull/19437
--
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
cmccabe commented on code in PR #19416:
URL: https://github.com/apache/kafka/pull/19416#discussion_r2053109111
##
metadata/src/main/java/org/apache/kafka/controller/FeatureControlManager.java:
##
@@ -225,6 +272,32 @@ private ApiError updateFeature(
if (featureName.equal
rreddy-22 commented on code in PR #19429:
URL: https://github.com/apache/kafka/pull/19429#discussion_r2053115299
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -273,17 +276,29 @@ public TransactionManager(final LogContext logC
rreddy-22 commented on code in PR #19429:
URL: https://github.com/apache/kafka/pull/19429#discussion_r2053117512
##
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java:
##
@@ -654,6 +657,46 @@ public void initTransactions() {
transactionManager.ma
FrankYang0529 commented on code in PR #19520:
URL: https://github.com/apache/kafka/pull/19520#discussion_r2052284015
##
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/ClientsTestUtils.java:
##
@@ -0,0 +1,198 @@
+/*
+ * Licensed to the Apache Software Fo
chia7712 commented on PR #19526:
URL: https://github.com/apache/kafka/pull/19526#issuecomment-2818302529
I'm going to merge it to unlock other PRs. Please feel free to leave
comments and we can address them in follow-up
--
This is an automated message from the Apache Git Service.
To respo
chia7712 merged PR #19526:
URL: https://github.com/apache/kafka/pull/19526
--
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 PR #19191:
URL: https://github.com/apache/kafka/pull/19191#issuecomment-2818304933
@FrankYang0529 please rebase code to include the fix
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
chia7712 commented on PR #19346:
URL: https://github.com/apache/kafka/pull/19346#issuecomment-2818305443
@Rancho-7 please rebase code to include recent fix
--
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-18933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-18933.
Fix Version/s: 4.1.0
Resolution: Fixed
> Add integration tests for :clients outside
Chia-Ping Tsai created KAFKA-19182:
--
Summary: Move SchedulerTest to server module
Key: KAFKA-19182
URL: https://issues.apache.org/jira/browse/KAFKA-19182
Project: Kafka
Issue Type: Sub-task
gongxuanzhang commented on code in PR #19525:
URL: https://github.com/apache/kafka/pull/19525#discussion_r2052352772
##
.github/scripts/junit.py:
##
@@ -361,7 +361,7 @@ def split_report_path(base_path: str, report_path: str) ->
Tuple[str, str]:
failure_messages.append(
chia7712 merged PR #17099:
URL: https://github.com/apache/kafka/pull/17099
--
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
PoAn Yang created KAFKA-19183:
-
Summary: Move Pool and PoolTest to server module
Key: KAFKA-19183
URL: https://issues.apache.org/jira/browse/KAFKA-19183
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-8830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-8830.
---
Fix Version/s: 4.1.0
Resolution: Fixed
> KIP-512: make Record Headers available in onA
Rancho-7 opened a new pull request, #19529:
URL: https://github.com/apache/kafka/pull/19529
jira: https://issues.apache.org/jira/browse/KAFKA-19178
The vector is a synchronized collection, and in the case we don't need to
sync. Also, we can use `Collections.enumeration` to convert col
93 matches
Mail list logo
