showuon commented on code in PR #18393:
URL: https://github.com/apache/kafka/pull/18393#discussion_r2030056754
##
storage/src/main/java/org/apache/kafka/storage/internals/log/LocalLog.java:
##
@@ -470,8 +470,8 @@ public FetchDataInfo read(long startOffset,
return maybeH
frankvicky commented on PR #17614:
URL: https://github.com/apache/kafka/pull/17614#issuecomment-2781237676
Hi @ableegoldman
A huge thanks for your patience and review! šš¼
> do you want to start working on the followup PR now to utilize this new
API for KafkaStreams#close?
Yes, I
ableegoldman commented on PR #17614:
URL: https://github.com/apache/kafka/pull/17614#issuecomment-2781223772
Merged to trunk (š„³ ) -- do you want to start working on the followup PR now
to utilize this new API for `KafkaStreams#close`? This will also let us clean
up the `internal.leave.group
LoganZhuZzz opened a new pull request, #19388:
URL: https://github.com/apache/kafka/pull/19388
This PR is a minor follow-up to [PR
#19320](https://github.com/apache/kafka/pull/19320), which cleaned up 0.10.x
legacy information from the clients module.
It addresses remaining reviewer
ableegoldman merged PR #17614:
URL: https://github.com/apache/kafka/pull/17614
--
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.ap
mjsax commented on PR #19303:
URL: https://github.com/apache/kafka/pull/19303#issuecomment-2781214593
Thanks for the patch! Merged to `trunk`, and cherry-picked to `4.0` and
`3.9` branches.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
sjhajharia commented on PR #19380:
URL: https://github.com/apache/kafka/pull/19380#issuecomment-2781209728
OffloadAndTxnConsumeFromLeaderTest -> Seems to be a flaky test
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
github-actions[bot] commented on PR #9493:
URL: https://github.com/apache/kafka/pull/9493#issuecomment-2781201685
This PR is being marked as stale since it has not had any activity in 90
days. If you
would like to keep this PR alive, please leave a comment asking for a
review. If the PR
[
https://issues.apache.org/jira/browse/KAFKA-19042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17941311#comment-17941311
]
PoAn Yang commented on KAFKA-19042:
---
Thanks. Updated it.
> Move kafka.api test cases
[
https://issues.apache.org/jira/browse/KAFKA-19042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
PoAn Yang updated KAFKA-19042:
--
Description:
This is an umbrella Jira about moving integration tests from kafka.api module
to clients
[
https://issues.apache.org/jira/browse/KAFKA-19042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
PoAn Yang updated KAFKA-19042:
--
Summary: Move kafka.api test cases to clients-integration-tests module
(was: Move kafka.api test case
github-actions[bot] commented on PR #18334:
URL: https://github.com/apache/kafka/pull/18334#issuecomment-2781197176
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 #19228:
URL: https://github.com/apache/kafka/pull/19228#issuecomment-2781197134
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
mjsax merged PR #19303:
URL: https://github.com/apache/kafka/pull/19303
--
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.or
[
https://issues.apache.org/jira/browse/KAFKA-18073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-18073:
Fix Version/s: (was: 4.1.0)
> Data loss when exception is raised from Kafka Connect re
frankvicky commented on code in PR #19383:
URL: https://github.com/apache/kafka/pull/19383#discussion_r2030020799
##
server-common/src/main/java/org/apache/kafka/config/BrokerReconfigurable.java:
##
@@ -27,13 +29,10 @@
* The reconfiguration process follows three steps:
*
gongxuanzhang commented on PR #19386:
URL: https://github.com/apache/kafka/pull/19386#issuecomment-2781166844
@chia7712 PTAL
--
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.
[
https://issues.apache.org/jira/browse/KAFKA-19096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-19096:
---
Assignee: Matthias J. Sax
> Skipped Records in FK join should not be marked as drop
[
https://issues.apache.org/jira/browse/KAFKA-14485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17941300#comment-17941300
]
Dmitry Werner commented on KAFKA-14485:
---
[~chia7712] [~mimaison] I've opened the P
wernerdv opened a new pull request, #19387:
URL: https://github.com/apache/kafka/pull/19387
Move LogCleaner and related classes to storage module and rewrite in Java.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
AyoubOm commented on code in PR #19303:
URL: https://github.com/apache/kafka/pull/19303#discussion_r2029961920
##
streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionSendProcessorSupplierTest.java:
##
@@ -316,6 +367,21 @@ public void inner
[
https://issues.apache.org/jira/browse/KAFKA-19096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ayoub Omari updated KAFKA-19096:
Description:
Currently, we are logging all skipped records in FK join as dropped.
This seems inco
Ayoub Omari created KAFKA-19096:
---
Summary: Skipped Records in FK join should not be marked as dropped
Key: KAFKA-19096
URL: https://issues.apache.org/jira/browse/KAFKA-19096
Project: Kafka
Issu
TaiJuWu commented on code in PR #19286:
URL: https://github.com/apache/kafka/pull/19286#discussion_r2022583314
##
core/src/test/java/kafka/log/remote/RemoteLogManagerTest.java:
##
@@ -413,24 +418,19 @@ void
testRemoteLogMetadataManagerWithEndpointConfigOverridden() throws IOExc
Rancho-7 commented on PR #19347:
URL: https://github.com/apache/kafka/pull/19347#issuecomment-2772098768
To verify the behavior, I ran the tests locally using the following
command,and the output is also shown below.
```
(base) lansg:kafka/ (KAFKA-19027ā) $ N=100; I=0; while [ $I -
ijuma commented on PR #19327:
URL: https://github.com/apache/kafka/pull/19327#issuecomment-2781041904
OK, if the concern is that this method is unsafe in prod, it's reasonable to
replace it with a test utility method.
--
This is an automated message from the Apache Git Service.
To respond
mumrah merged PR #19248:
URL: https://github.com/apache/kafka/pull/19248
--
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-19050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17938882#comment-17938882
]
Chia-Ping Tsai commented on KAFKA-19050:
[~utkuaydin] do you mean we should move
lucasbru merged PR #18383:
URL: https://github.com/apache/kafka/pull/18383
--
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
lucasbru commented on code in PR #19219:
URL: https://github.com/apache/kafka/pull/19219#discussion_r2028473669
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -8148,7 +8174,10 @@ private TaskAssignor streamsGroupAssignor(St
[
https://issues.apache.org/jira/browse/KAFKA-18713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17939766#comment-17939766
]
Stanislav Spiridonov commented on KAFKA-18713:
--
# 4.0.0 is released, but th
Apoorv Mittal created KAFKA-19019:
-
Summary: Verify Share Fetch with Tiered Storage
Key: KAFKA-19019
URL: https://issues.apache.org/jira/browse/KAFKA-19019
Project: Kafka
Issue Type: Sub-task
mjsax commented on code in PR #19005:
URL: https://github.com/apache/kafka/pull/19005#discussion_r2026065811
##
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinIntegrationTest.java:
##
@@ -232,57 +236,134 @@ public void doJo
dajac commented on code in PR #19251:
URL: https://github.com/apache/kafka/pull/19251#discussion_r2005969287
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -1635,40 +1635,8 @@ class KafkaApis(val requestChannel: RequestChannel,
trace(s"End transaction marker a
Parkerhiphop commented on PR #19213:
URL: https://github.com/apache/kafka/pull/19213#issuecomment-2741254322
Since the reset behavior has changed, it now resets the configs to their
default values instead of leaving them empty as before.
Hereās a screenshot of the reset behaviorāinter
mimaison commented on PR #19280:
URL: https://github.com/apache/kafka/pull/19280#issuecomment-2750753505
> Somehow, I was convinced that it was executed automatically now every
quarter.
Me too! But it does not seem to be the case.
--
This is an automated message from the Apache Git
AndrewJSchofield merged PR #19254:
URL: https://github.com/apache/kafka/pull/19254
--
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...@kafk
apalan60 commented on PR #19274:
URL: https://github.com/apache/kafka/pull/19274#issuecomment-2759098547
I ran a few tests, and so far I have successfully invoked 14 nodes, with the
tests remaining stable.
 throws Exception {
beginShutdown(
github-actions[bot] commented on PR #19029:
URL: https://github.com/apache/kafka/pull/19029#issuecomment-2764362494
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 #18912:
URL: https://github.com/apache/kafka/pull/18912#issuecomment-2764362509
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
dajac merged PR #19251:
URL: https://github.com/apache/kafka/pull/19251
--
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.or
adixitconfluent commented on code in PR #19261:
URL: https://github.com/apache/kafka/pull/19261#discussion_r2026267169
##
core/src/main/java/kafka/server/share/SharePartition.java:
##
@@ -1246,7 +1259,9 @@ private boolean archiveAvailableRecords(long startOffset,
long endOffset
[
https://issues.apache.org/jira/browse/KAFKA-19004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-19004:
--
Assignee: xuanzhang gong (was: Chia-Ping Tsai)
> Move DelayedDeleteRecords to server
nilmadhab commented on PR #19005:
URL: https://github.com/apache/kafka/pull/19005#issuecomment-2774512670
@mjsax LGTM
--
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 uns
ijuma commented on PR #15968:
URL: https://github.com/apache/kafka/pull/15968#issuecomment-2743945863
@OmniaGM Would you like someone to help get this over the finish line?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
lianetm commented on code in PR #19281:
URL: https://github.com/apache/kafka/pull/19281#discussion_r2016344814
##
core/src/test/scala/unit/kafka/server/ConsumerGroupDescribeRequestTest.scala:
##
@@ -37,15 +37,17 @@ import java.lang.{Byte => JByte}
import java.util.Collections
apoorvmittal10 commented on code in PR #19261:
URL: https://github.com/apache/kafka/pull/19261#discussion_r2013454652
##
core/src/main/java/kafka/server/share/SharePartition.java:
##
@@ -2484,6 +2497,259 @@ private long startOffsetDuringInitialization(long
partitionDataStartOff
JosĆ© Armando GarcĆa Sancio created KAFKA-19021:
--
Summary: Broker should not be allowed to be promoted to controller
Key: KAFKA-19021
URL: https://issues.apache.org/jira/browse/KAFKA-19021
github-actions[bot] commented on PR #17753:
URL: https://github.com/apache/kafka/pull/17753#issuecomment-2739046191
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
AndrewJSchofield commented on PR #19313:
URL: https://github.com/apache/kafka/pull/19313#issuecomment-2772915350
@DL1231 Of course, the reason is that the limit is being applied per group
coordinator shard. Hmmm. This is not so straightforward.
--
This is an automated message from the Apa
bachmanity1 commented on PR #18828:
URL: https://github.com/apache/kafka/pull/18828#issuecomment-2765563652
> > but we're facing an issueāPlainSaslServer can only pass the
authorizationID to the authorizer, meaning the client info is lost.
>
> Have you considered implementing a custom
Chia-Ping Tsai created KAFKA-19074:
--
Summary: Remove the cached responseData from ShareFetchResponse
Key: KAFKA-19074
URL: https://issues.apache.org/jira/browse/KAFKA-19074
Project: Kafka
Is
TaiJuWu commented on code in PR #19050:
URL: https://github.com/apache/kafka/pull/19050#discussion_r2028375807
##
metadata/src/main/java/org/apache/kafka/metadata/publisher/AclPublisher.java:
##
@@ -103,6 +105,9 @@ public void onMetadataUpdate(MetadataDelta delta,
MetadataImage
chia7712 commented on code in PR #19325:
URL: https://github.com/apache/kafka/pull/19325#discussion_r2021372461
##
clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java:
##
@@ -67,11 +66,11 @@ public enum ApiKeys {
DELETE_RECORDS(ApiMessageType.DELETE_RECORDS)
chia7712 commented on code in PR #19226:
URL: https://github.com/apache/kafka/pull/19226#discussion_r2020587635
##
core/src/main/scala/kafka/server/ReplicaManager.scala:
##
@@ -1282,8 +1281,31 @@ class ReplicaManager(val config: KafkaConfig,
}
if (delayedDeleteRecord
dajac opened a new pull request, #19273:
URL: https://github.com/apache/kafka/pull/19273
This patch fixes another bug in the FindCoordinator API handling for share
partition key. `shareCoordinator.foreach` returns `Unit` so
`shareCoordinator.foreach(coordinator =>
coordinator.partitionFor(
ijuma commented on code in PR #19167:
URL: https://github.com/apache/kafka/pull/19167#discussion_r2009192580
##
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java:
##
@@ -286,4 +291,12 @@ private static FetchResponseData toMessage(Errors error,
chia7712 merged PR #19305:
URL: https://github.com/apache/kafka/pull/19305
--
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
FrƩdƩrik ROULEAU created KAFKA-19051:
Summary: Fix implicit acknowledgement cannot be override when
RecordDeserializationException occurs
Key: KAFKA-19051
URL: https://issues.apache.org/jira/browse/KAFKA-19051
ShivsundarR commented on code in PR #19335:
URL: https://github.com/apache/kafka/pull/19335#discussion_r2022361659
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumerImpl.java:
##
@@ -250,6 +251,7 @@ private enum AcknowledgementMode {
[
https://issues.apache.org/jira/browse/KAFKA-19079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17940811#comment-17940811
]
oshione gabriel esiemokhai commented on KAFKA-19079:
hello ,what doe
frankvicky commented on code in PR #19277:
URL: https://github.com/apache/kafka/pull/19277#discussion_r2011287595
##
storage/src/test/java/org/apache/kafka/storage/internals/log/BrokerCompressionTest.java:
##
@@ -0,0 +1,117 @@
+/*
+ * Licensed to the Apache Software Foundation (
[
https://issues.apache.org/jira/browse/KAFKA-19026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Edoardo Comar updated KAFKA-19026:
--
Attachment: KAFKA19026Test.java
> AlterConfigPolicy incompatibility between ZK mode and KRaft
kirktrue commented on PR #19199:
URL: https://github.com/apache/kafka/pull/19199#issuecomment-2767702063
@lorcanjāLooking at the [test history of
`CooperativeConsumerCoordinatorTest.testOutdatedCoordinatorAssignment()`](https://develocity.apache.org/scans/tests?search.relativeStartTime=P28D&
chia7712 commented on PR #19223:
URL: https://github.com/apache/kafka/pull/19223#issuecomment-2752082932
> The fixed version for
[KAFKA-18723](https://issues.apache.org/jira/browse/KAFKA-18723) already
includes 3.9.1 and 4.0.1?
I grep the git history , and KAFKA-18723 is not in 4.0/3
squah-confluent closed pull request #19260: KAFKA-19025: Reuse LZ4 buffers for
compression
URL: https://github.com/apache/kafka/pull/19260
--
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 specifi
jsancio commented on code in PR #18987:
URL: https://github.com/apache/kafka/pull/18987#discussion_r2004145500
##
raft/src/test/java/org/apache/kafka/raft/RaftEventSimulationTest.java:
##
@@ -475,6 +563,99 @@ void canRecoverFromSingleNodeCommittedDataLoss(
scheduler.run
mumrah opened a new pull request, #63:
URL: https://github.com/apache/kafka-merge-queue-sandbox/pull/63
(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 unsu
srdo opened a new pull request, #19367:
URL: https://github.com/apache/kafka/pull/19367
This was done on trunk in 6a37d5ccebaa6bbfc1d1b943f0ff761cf978da7d
--
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 t
chia7712 commented on PR #19327:
URL: https://github.com/apache/kafka/pull/19327#issuecomment-2781010552
@ijuma thanks for your explanation. I do agree that there is no strict
requirement of removing a test-only method. However, `nodeEndpoints` is crucial
for handling specific errors like `
mumrah merged PR #68:
URL: https://github.com/apache/kafka-merge-queue-sandbox/pull/68
--
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...@
chia7712 commented on PR #19085:
URL: https://github.com/apache/kafka/pull/19085#issuecomment-2742992871
@sjhajharia could you please rebase code? there is a build error if I apply
this PR on the trunk.
--
This is an automated message from the Apache Git Service.
To respond to the message
chia7712 commented on code in PR #18795:
URL: https://github.com/apache/kafka/pull/18795#discussion_r2004284732
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractFetch.java:
##
@@ -432,7 +439,14 @@ protected Map
prepareFetchRequests()
smjn commented on code in PR #19328:
URL: https://github.com/apache/kafka/pull/19328#discussion_r2024607201
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java:
##
@@ -1365,6 +1368,67 @@ public
CompletableFuture
describeShareGroup
[
https://issues.apache.org/jira/browse/KAFKA-18827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sushant Mahajan resolved KAFKA-18827.
-
Resolution: Fixed
> Initialize share group state impl
>
[
https://issues.apache.org/jira/browse/KAFKA-19068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17940093#comment-17940093
]
Nick Guo commented on KAFKA-19068:
--
Hi [~chia7712] ,I would like to handle this.Thanks!
jeqo opened a new pull request, #19331:
URL: https://github.com/apache/kafka/pull/19331
Backports f24945b519005c0bc7a28db2db7aae6cec158927 to 4.0
Instead of reopening the transaction index, it cancels the RemoteFetchTask
without interrupting it--avoiding to close the TransactionIndex
[
https://issues.apache.org/jira/browse/KAFKA-19012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-19012:
--
Component/s: clients
producer
> Messages ending up on the wrong topic
>
mumrah merged PR #66:
URL: https://github.com/apache/kafka-merge-queue-sandbox/pull/66
--
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...@
Tombert commented on code in PR #19366:
URL: https://github.com/apache/kafka/pull/19366#discussion_r2027542000
##
clients/src/main/java/org/apache/kafka/clients/consumer/AcknowledgementCommitCallback.java:
##
@@ -34,6 +34,7 @@
* The callback may be executed in any thread calli
fvaleri commented on code in PR #19198:
URL: https://github.com/apache/kafka/pull/19198#discussion_r1999330309
##
docs/upgrade.html:
##
@@ -72,10 +72,8 @@ Upgrading
Servers to 4.0.0 from
brokers will be running the latest version and you can verify that the
cluster's
JimmyWang6 commented on PR #18929:
URL: https://github.com/apache/kafka/pull/18929#issuecomment-2765640456
Hi @AndrewJSchofield,
Sorry for the delay. I've been occupied with other tasks recently, but I
will start to work on this issue as soon as possible. Much thanks for your help.
--
Chia-Ping Tsai created KAFKA-19030:
--
Summary: Remove metricNamePrefix from RequestChannel
Key: KAFKA-19030
URL: https://issues.apache.org/jira/browse/KAFKA-19030
Project: Kafka
Issue Type: I
josefk31 commented on PR #19362:
URL: https://github.com/apache/kafka/pull/19362#issuecomment-2776483452
Testing:
```
--
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.
[
https://issues.apache.org/jira/browse/KAFKA-19003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ritika Reddy resolved KAFKA-19003.
--
Resolution: Fixed
> Add force-terminate feature to kafka-transactions CLI and Admin Client
>
ijuma commented on code in PR #19250:
URL: https://github.com/apache/kafka/pull/19250#discussion_r200354
##
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java:
##
@@ -234,9 +229,10 @@
* successful writes are marked as aborted, hence keeping the tran
Tombert commented on code in PR #19234:
URL: https://github.com/apache/kafka/pull/19234#discussion_r2025864206
##
streams/src/main/java/org/apache/kafka/streams/kstream/EmitStrategy.java:
##
@@ -29,6 +29,7 @@
/**
* This interface controls the strategy that can be used to cont
[
https://issues.apache.org/jira/browse/KAFKA-15580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17940127#comment-17940127
]
Jonah Hooper commented on KAFKA-15580:
--
This is being actively worked on; the actua
mumrah commented on code in PR #19240:
URL: https://github.com/apache/kafka/pull/19240#discussion_r2004033069
##
metadata/src/test/java/org/apache/kafka/controller/QuorumControllerTest.java:
##
@@ -376,10 +375,12 @@ public void testElrEnabledByDefault() throws Throwable {
[
https://issues.apache.org/jira/browse/KAFKA-19080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-19080:
--
Assignee: é»ē«£é½
> The constraint on segment.ms is not enforced at topic level
> ---
wernerdv commented on code in PR #19216:
URL: https://github.com/apache/kafka/pull/19216#discussion_r2007200264
##
storage/src/main/java/org/apache/kafka/storage/internals/log/LogToClean.java:
##
@@ -0,0 +1,149 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under on
[
https://issues.apache.org/jira/browse/KAFKA-17354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17939350#comment-17939350
]
Ao Li edited comment on KAFKA-17354 at 3/28/25 11:41 PM:
-
We rec
smjn commented on code in PR #19369:
URL: https://github.com/apache/kafka/pull/19369#discussion_r2028490277
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumeRequestManager.java:
##
@@ -971,9 +971,11 @@ private void
handlePartitionError(ShareAckno
dajac merged PR #19243:
URL: https://github.com/apache/kafka/pull/19243
--
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.or
[
https://issues.apache.org/jira/browse/KAFKA-19003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ritika Reddy updated KAFKA-19003:
-
Description: TheĀ {{kafka-transactions.sh}} tool is going to support a new
command forceTerminate
Chia-Ping Tsai created KAFKA-19056:
--
Summary: Move EndToEndClusterIdTest to server module
Key: KAFKA-19056
URL: https://issues.apache.org/jira/browse/KAFKA-19056
Project: Kafka
Issue Type: I
[
https://issues.apache.org/jira/browse/KAFKA-19055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-19055.
Fix Version/s: 4.1.0
Resolution: Fixed
> Cleanup the 0.10.x information from client
[
https://issues.apache.org/jira/browse/KAFKA-19061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ritika Reddy updated KAFKA-19061:
-
Description:
*transaction.max.timeout.ms*Ā guarantees that an ongoing transaction is aborted
wit
1 - 100 of 252 matches
Mail list logo
