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-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
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-12715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17939866#comment-17939866
]
Jaideep Cuttamanchi commented on KAFKA-12715:
-
Hi I can contribute to this f
[
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
chia7712 commented on code in PR #19251:
URL: https://github.com/apache/kafka/pull/19251#discussion_r2006087036
##
core/src/test/scala/unit/kafka/server/HeartbeatRequestTest.scala:
##
@@ -36,17 +36,7 @@ class HeartbeatRequestTest(cluster: ClusterInstance) extends
GroupCoordinat
[
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
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-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
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-15931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17937171#comment-17937171
]
Jun Rao commented on KAFKA-15931:
-
Merged [https://github.com/apache/kafka/pull/19197] t
[
https://issues.apache.org/jira/browse/KAFKA-19051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17939719#comment-17939719
]
Andrew Schofield commented on KAFKA-19051:
--
Hmm. This is a pretty small corner
chia7712 merged PR #19270:
URL: https://github.com/apache/kafka/pull/19270
--
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-19070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lorcan reassigned KAFKA-19070:
--
Assignee: Lorcan
> Adding task number to the user provided client id (via
> consumer.override.client
adixitconfluent commented on code in PR #19261:
URL: https://github.com/apache/kafka/pull/19261#discussion_r2026273027
##
core/src/main/java/kafka/server/share/SharePartition.java:
##
@@ -2484,6 +2505,174 @@ private long startOffsetDuringInitialization(long
partitionDataStartOf
AyoubOm commented on code in PR #19303:
URL: https://github.com/apache/kafka/pull/19303#discussion_r2029819976
##
streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionSendProcessorSupplierTest.java:
##
@@ -316,6 +367,21 @@ public void inner
AyoubOm commented on code in PR #19303:
URL: https://github.com/apache/kafka/pull/19303#discussion_r2029817657
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionSendProcessorSupplier.java:
##
@@ -143,28 +143,25 @@ private void leftJoi
[
https://issues.apache.org/jira/browse/KAFKA-19074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-19074.
Fix Version/s: 4.1.0
Resolution: Fixed
> Remove the cached responseData from ShareF
AyoubOm commented on code in PR #15607:
URL: https://github.com/apache/kafka/pull/15607#discussion_r2029852092
##
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinIntegrationTest.java:
##
@@ -795,6 +796,12 @@ protected static
kumarpritam863 commented on PR #19341:
URL: https://github.com/apache/kafka/pull/19341#issuecomment-2780684838
@dajac can we please review this and also let me know if this requires any
KIP.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
chia7712 merged PR #19288:
URL: https://github.com/apache/kafka/pull/19288
--
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
Rancho-7 commented on code in PR #19384:
URL: https://github.com/apache/kafka/pull/19384#discussion_r2029898652
##
core/src/main/scala/kafka/server/KafkaRequestHandler.scala:
##
@@ -208,7 +208,7 @@ class KafkaRequestHandlerPool(
/* a meter to track the average free capacity o
mimaison opened a new pull request, #19385:
URL: https://github.com/apache/kafka/pull/19385
A bunch of Java 17 cleanups
--
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-14485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17941260#comment-17941260
]
Mickael Maison commented on KAFKA-14485:
Taking a quick look, it seems you could
m1a2st commented on PR #19385:
URL: https://github.com/apache/kafka/pull/19385#issuecomment-2780886679
Thanks for this patch, I think this is dulpicate with
https://github.com/apache/kafka/pull/19372
--
This is an automated message from the Apache Git Service.
To respond to the message, p
fhussonnois commented on PR #19188:
URL: https://github.com/apache/kafka/pull/19188#issuecomment-2780914918
Hey @mjsax, sorry for the delay. I've rewritten the `MockConsumer#poll`
method into something straightforward.
--
This is an automated message from the Apache Git Service.
To respon
mjsax commented on code in PR #19303:
URL: https://github.com/apache/kafka/pull/19303#discussion_r2029913190
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionSendProcessorSupplier.java:
##
@@ -143,28 +143,25 @@ private void leftJoinI
ijuma commented on PR #19327:
URL: https://github.com/apache/kafka/pull/19327#issuecomment-2780917690
I don't understand what we are trying to achieve here. It would be good to
agree on the goal first. Generally speaking, it's not a strict requirement to
remove a method if it's only used by
mumrah merged PR #19242:
URL: https://github.com/apache/kafka/pull/19242
--
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
TaiJuWu commented on code in PR #19383:
URL: https://github.com/apache/kafka/pull/19383#discussion_r2029911586
##
server-common/src/main/java/org/apache/kafka/config/BrokerReconfigurable.java:
##
@@ -27,13 +29,10 @@
* The reconfiguration process follows three steps:
*
*
mjsax commented on code in PR #19303:
URL: https://github.com/apache/kafka/pull/19303#discussion_r2029914078
##
streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionSendProcessorSupplierTest.java:
##
@@ -316,6 +367,21 @@ public void innerJo
Justine Olshan created KAFKA-19079:
--
Summary: KIP-890 Cleanups
Key: KAFKA-19079
URL: https://issues.apache.org/jira/browse/KAFKA-19079
Project: Kafka
Issue Type: Improvement
Repo
jolshan commented on code in PR #19193:
URL: https://github.com/apache/kafka/pull/19193#discussion_r1999826233
##
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionCoordinatorTest.scala:
##
@@ -967,12 +1023,16 @@ class TransactionCoordinatorTest {
validateR
AndrewJSchofield commented on PR #19313:
URL: https://github.com/apache/kafka/pull/19313#issuecomment-2772173039
@DL1231 Thanks for the PR. Please can you resolve the conflicts.
Also, I tried the branch out on my local environment and was successfully
able to create more than `group.s
Sean Quah created KAFKA-19025:
-
Summary: Reuse buffers for LZ4 compression
Key: KAFKA-19025
URL: https://issues.apache.org/jira/browse/KAFKA-19025
Project: Kafka
Issue Type: Improvement
aliehsaeedii opened a new pull request, #19360:
URL: https://github.com/apache/kafka/pull/19360
This is a minor fix for this PR: https://github.com/apache/kafka/pull/19176
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and us
Chia-Ping Tsai created KAFKA-19076:
--
Summary: UnifiedLog#maybeHandleIOException should replace `String`
by `Supplier`
Key: KAFKA-19076
URL: https://issues.apache.org/jira/browse/KAFKA-19076
Project:
bbejeck opened a new pull request, #19326:
URL: https://github.com/apache/kafka/pull/19326
Enhances the error messages logged during task commit failures by including
the specific cause from the `TimeoutException`. This provides clearer context
to debug issues related to timeout errors.
github-actions[bot] commented on PR #13320:
URL: https://github.com/apache/kafka/pull/13320#issuecomment-2771264351
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 P
AyoubOm commented on code in PR #15607:
URL: https://github.com/apache/kafka/pull/15607#discussion_r2029857497
##
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinIntegrationTest.java:
##
@@ -795,6 +796,12 @@ protected static
frankvicky commented on code in PR #17614:
URL: https://github.com/apache/kafka/pull/17614#discussion_r2029880923
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerHeartbeatRequestManager.java:
##
@@ -211,6 +214,29 @@ public ConsumerMembershipManager m
[
https://issues.apache.org/jira/browse/KAFKA-19094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TengYao Chi updated KAFKA-19094:
Labels: need-kip (was: )
> Add a mechanism to GroupMetadataManager for handling static members le
frankvicky commented on code in PR #17614:
URL: https://github.com/apache/kafka/pull/17614#discussion_r2029885686
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerMembershipManager.java:
##
@@ -469,8 +493,17 @@ public int joinGroupEpoch() {
*/
TengYao Chi created KAFKA-19094:
---
Summary: Add a mechanism to GroupMetadataManager for handling
static members leaving groups
Key: KAFKA-19094
URL: https://issues.apache.org/jira/browse/KAFKA-19094
Proj
[
https://issues.apache.org/jira/browse/KAFKA-14485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17941248#comment-17941248
]
Chia-Ping Tsai commented on KAFKA-14485:
[~javakillah] there is already a minor
dajac commented on code in PR #19333:
URL: https://github.com/apache/kafka/pull/19333#discussion_r2023181017
##
coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/CoordinatorRuntimeTest.java:
##
@@ -649,42 +649,37 @@ public void
testScheduleUnloadingWi
FrankYang0529 commented on code in PR #19319:
URL: https://github.com/apache/kafka/pull/19319#discussion_r2028317810
##
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/producer/ProducerCompressionTest.java:
##
@@ -0,0 +1,185 @@
+/*
+ * Licensed to the Ap
AndrewJSchofield commented on PR #19295:
URL: https://github.com/apache/kafka/pull/19295#issuecomment-2769293324
Build failure due to excessively flaky test. Test disabled by
https://github.com/apache/kafka/pull/19340.
--
This is an automated message from the Apache Git Service.
To respon
lucasbru commented on code in PR #19219:
URL: https://github.com/apache/kafka/pull/19219#discussion_r2020722085
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -15294,221 +15314,2860 @@ public void testShareGroupStates()
[
https://issues.apache.org/jira/browse/KAFKA-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kevin Apolinario reassigned KAFKA-10357:
Assignee: Kevin Apolinario (was: Bruno Cadonna)
> Handle accidental deletion of
[
https://issues.apache.org/jira/browse/KAFKA-14895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan updated KAFKA-14895:
---
Parent Issue: KAFKA-19079 (was: KAFKA-14402)
> Move AddPartitionsToTxnManager files to java
apoorvmittal10 commented on code in PR #19261:
URL: https://github.com/apache/kafka/pull/19261#discussion_r2021428929
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupConfig.java:
##
@@ -290,6 +309,10 @@ public static ShareGroupAutoOffsetResetStrategy
mimaison commented on code in PR #19068:
URL: https://github.com/apache/kafka/pull/19068#discussion_r2027393106
##
clients/clients-integration-tests/src/test/java/org/apache/kafka/server/quota/CustomQuotaCallbackTest.java:
##
@@ -69,10 +70,37 @@ public void testCustomQuotaCallba
mimaison commented on code in PR #19246:
URL: https://github.com/apache/kafka/pull/19246#discussion_r2006447637
##
raft/src/main/java/org/apache/kafka/raft/MetadataLogConfig.java:
##
@@ -0,0 +1,61 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ *
lorcanj commented on code in PR #19199:
URL: https://github.com/apache/kafka/pull/19199#discussion_r2004905258
##
clients/src/main/java/org/apache/kafka/clients/Metadata.java:
##
@@ -422,21 +423,17 @@ public synchronized Set
updatePartitionLeadership(Map
apalan60 commented on PR #19327:
URL: https://github.com/apache/kafka/pull/19327#issuecomment-2780865513
Hi @junrao , @ijuma , @FrankYang0529
Sorry for the late update. I’ve now updated the PR with the following
adjustments:
In the original version, FetchResponse had two ```#of``
apalan60 commented on code in PR #19327:
URL: https://github.com/apache/kafka/pull/19327#discussion_r2029901777
##
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java:
##
@@ -220,14 +220,6 @@ public static int
recordsSize(FetchResponseData.PartitionData pa
MeloHenrique commented on PR #12331:
URL: https://github.com/apache/kafka/pull/12331#issuecomment-2780869437
Does anyone know if the problem still persists with v4.0?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
mjsax commented on code in PR #18837:
URL: https://github.com/apache/kafka/pull/18837#discussion_r2025469495
##
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/StreamsUncaughtExceptionHandlerIntegrationTest.java:
##
@@ -192,7 +192,7 @@ private static
[
https://issues.apache.org/jira/browse/KAFKA-14485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17941224#comment-17941224
]
Chia-Ping Tsai commented on KAFKA-14485:
{code:java}
diff --git
a/core/src/ma
frankvicky commented on code in PR #17614:
URL: https://github.com/apache/kafka/pull/17614#discussion_r2029835345
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerMembershipManager.java:
##
@@ -469,8 +493,17 @@ public int joinGroupEpoch() {
*/
frankvicky commented on code in PR #17614:
URL: https://github.com/apache/kafka/pull/17614#discussion_r2029835345
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerMembershipManager.java:
##
@@ -469,8 +493,17 @@ public int joinGroupEpoch() {
*/
lorcanj opened a new pull request, #19382:
URL: https://github.com/apache/kafka/pull/19382
Addresses: [KAFKA-19070](https://issues.apache.org/jira/browse/KAFKA-19070)
The default clientId for the connector consumer is 'connector-consumer-'
plus the task id value. When a user overrides
lorcanj commented on PR #19382:
URL: https://github.com/apache/kafka/pull/19382#issuecomment-2780662680
I think this may require a KIP as this would potentially break some client
code if people try to do matching on the overridden client id which would no
longer match as the string would be
frankvicky commented on code in PR #17614:
URL: https://github.com/apache/kafka/pull/17614#discussion_r2029841125
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerMembershipManager.java:
##
@@ -469,8 +493,17 @@ public int joinGroupEpoch() {
*/
Rancho-7 commented on code in PR #19384:
URL: https://github.com/apache/kafka/pull/19384#discussion_r2029898652
##
core/src/main/scala/kafka/server/KafkaRequestHandler.scala:
##
@@ -208,7 +208,7 @@ class KafkaRequestHandlerPool(
/* a meter to track the average free capacity o
chia7712 merged PR #19357:
URL: https://github.com/apache/kafka/pull/19357
--
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 #19374:
URL: https://github.com/apache/kafka/pull/19374#issuecomment-2780689476
> could we also remove DataPlaneAcceptor#ThreadPrefix and
DataPlaneAcceptor#MetricPrefix, because the only implementation of Acceptor is
DataPlaneAcceptor?
`DataPlaneAcceptor#Metr
yx9o opened a new pull request, #19244:
URL: https://github.com/apache/kafka/pull/19244
Add doc for configuration parameters to keep the format consistent.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
AyoubOm commented on code in PR #15607:
URL: https://github.com/apache/kafka/pull/15607#discussion_r2029852092
##
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinIntegrationTest.java:
##
@@ -795,6 +796,12 @@ protected static
frankvicky opened a new pull request, #19383:
URL: https://github.com/apache/kafka/pull/19383
This patch moves `BrokerReconfigurable` to the `server-common module` and
decouples the `TransactionLogConfig` and `KafkaConfig` to unblock KAFKA-14485.
--
This is an automated message from the A
chia7712 commented on code in PR #19374:
URL: https://github.com/apache/kafka/pull/19374#discussion_r2029852866
##
core/src/main/scala/kafka/network/SocketServer.scala:
##
@@ -97,7 +97,7 @@ class SocketServer(
private val memoryPool = if (config.queuedMaxBytes > 0) new
Simpl
AyoubOm commented on code in PR #19303:
URL: https://github.com/apache/kafka/pull/19303#discussion_r2029817657
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionSendProcessorSupplier.java:
##
@@ -143,28 +143,25 @@ private void leftJoi
[
https://issues.apache.org/jira/browse/KAFKA-19095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cheng Yi Chang reassigned KAFKA-19095:
--
Assignee: Cheng Yi Chang (was: Chia-Ping Tsai)
> enhance the docs of incrementalAlte
chia7712 merged PR #19177:
URL: https://github.com/apache/kafka/pull/19177
--
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
m1a2st commented on code in PR #19384:
URL: https://github.com/apache/kafka/pull/19384#discussion_r2029892934
##
core/src/main/scala/kafka/server/KafkaRequestHandler.scala:
##
@@ -208,7 +208,7 @@ class KafkaRequestHandlerPool(
/* a meter to track the average free capacity of
chia7712 merged PR #19361:
URL: https://github.com/apache/kafka/pull/19361
--
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
Rancho-7 opened a new pull request, #19384:
URL: https://github.com/apache/kafka/pull/19384
jira: https://issues.apache.org/jira/browse/KAFKA-19093
> INFO [data-plane Kafka Request Handler on Broker 3000], Resizing request
handler thread pool size from 8 to 10 (kafka.server.KafkaReque
Chia-Ping Tsai created KAFKA-19095:
--
Summary: enhance the docs of incrementalAlterConfigs to remind
that controller only apply the cluster-level dynamic configurations
Key: KAFKA-19095
URL: https://issues.apache.
[
https://issues.apache.org/jira/browse/KAFKA-19042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17941253#comment-17941253
]
Jhen-Yung Hsu commented on KAFKA-19042:
---
Nit: client-integration-tests -> clients-
gongxuanzhang commented on PR #19319:
URL: https://github.com/apache/kafka/pull/19319#issuecomment-2780814259
@FrankYang0529
Thanks for your nice review, I updated this PR. PTAL
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
chia7712 commented on code in PR #19327:
URL: https://github.com/apache/kafka/pull/19327#discussion_r2029894525
##
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java:
##
@@ -220,14 +220,6 @@ public static int
recordsSize(FetchResponseData.PartitionData pa
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(
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
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 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
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,
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
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
[
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
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
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
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
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
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
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&
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
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
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
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
101 - 200 of 252 matches
Mail list logo
