cadonna commented on PR #19880:
URL: https://github.com/apache/kafka/pull/19880#issuecomment-2975408545
I would not open a PR against 1.4. The release branch is cut and it does not
seem that this change is critical to the release. I will set the `Fixed
Version` field for this ticket to `4.2
FrankYang0529 commented on PR #19932:
URL: https://github.com/apache/kafka/pull/19932#issuecomment-2976195389
@chia7712 I add a unit test `testLowercaseControllerListenerNames` for it.
Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please l
lucasbru commented on PR #19964:
URL: https://github.com/apache/kafka/pull/19964#issuecomment-2975852521
@junrao I redeployed the soak with the fix. I will report back if the
problem reoccurs
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
m1a2st opened a new pull request, #19971:
URL: https://github.com/apache/kafka/pull/19971
Use Java to rewrite ProducerSendWhileDeletionTest by new test infra and move
it to client-integration-tests module.
--
This is an automated message from the Apache Git Service.
To respond to the mess
[
https://issues.apache.org/jira/browse/KAFKA-16906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kaushik Raina resolved KAFKA-16906.
---
Resolution: Fixed
> Add consistent error handling for Transactions
> ---
apoorvmittal10 merged PR #19969:
URL: https://github.com/apache/kafka/pull/19969
--
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.
apoorvmittal10 opened a new pull request, #19969:
URL: https://github.com/apache/kafka/pull/19969
Fixing build after cherrypicking:
```
commit 254c1fa519b37bddc2488e80979406129fd56808
Author: Apoorv Mittal
Date: Thu Jun 12 22:52:50 2025 +0100
MINOR: Fixing clien
k-raina commented on PR #19931:
URL: https://github.com/apache/kafka/pull/19931#issuecomment-2975598598
@mimaison Sorry missed your ping on PR.
I have closed respective JIRAs
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
k-raina opened a new pull request, #19970:
URL: https://github.com/apache/kafka/pull/19970
## Problem
The current issue is that when a client sends a push telemetry request with
a compression type different from the broker's preferred compression type (the
first in the list of supported
[
https://issues.apache.org/jira/browse/KAFKA-19283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kaushik Raina resolved KAFKA-19283.
---
Resolution: Fixed
> Update Apache kafka public documentation
> -
Rancho-7 opened a new pull request, #19968:
URL: https://github.com/apache/kafka/pull/19968
this is a follow-up for https://github.com/apache/kafka/pull/19685
The timeout issue in `AsyncConsumer#unsubscribe` was fixed by
https://github.com/apache/kafka/pull/19779. As a result, the tes
[
https://issues.apache.org/jira/browse/KAFKA-18462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna resolved KAFKA-18462.
---
Resolution: Fixed
> Upgrade RocksDB dependency from 9.7.3 to something newer
> -
[
https://issues.apache.org/jira/browse/KAFKA-18462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-18462:
--
Fix Version/s: 4.2.0
(was: 4.1.0)
> Upgrade RocksDB dependency from 9.7
[
https://issues.apache.org/jira/browse/KAFKA-19409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna reassigned KAFKA-19409:
-
Assignee: (was: Kuan Po Tseng)
> CLONE - Upgrade RocksDB dependency from 10.1.3 to
[
https://issues.apache.org/jira/browse/KAFKA-19409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-19409:
--
Affects Version/s: 4.2.0
(was: 4.0.0)
> CLONE - Upgrade RocksDB dep
Bruno Cadonna created KAFKA-19409:
-
Summary: CLONE - Upgrade RocksDB dependency from 10.1.3 to
something newer
Key: KAFKA-19409
URL: https://issues.apache.org/jira/browse/KAFKA-19409
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-19409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-19409:
--
Description:
We will upgrade RocksDB to 10.1.3 with 4.2 release.
We should evaluate if we ca
[
https://issues.apache.org/jira/browse/KAFKA-19409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-19409:
--
Fix Version/s: 4.3.0
(was: 4.2.0)
> CLONE - Upgrade RocksDB dependency
[
https://issues.apache.org/jira/browse/KAFKA-19409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-19409:
--
Summary: Upgrade RocksDB dependency from 10.1.3 to something newer (was:
CLONE - Upgrade Rock
jim0987795064 commented on PR #19776:
URL: https://github.com/apache/kafka/pull/19776#issuecomment-2976377683
Hello, @chia7712 @m1a2st I've addressed the issues mentioned above.
Could you please review these? Many Thanks!
--
This is an automated message from the Apache Git Service.
To r
[
https://issues.apache.org/jira/browse/KAFKA-19409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17979229#comment-17979229
]
Bruno Cadonna commented on KAFKA-19409:
---
[~maheshsambaram] Thank you for your inte
chia7712 merged PR #19966:
URL: https://github.com/apache/kafka/pull/19966
--
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-19409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17979236#comment-17979236
]
Mahesh Sambaram edited comment on KAFKA-19409 at 6/16/25 1:47 PM:
chia7712 commented on code in PR #19932:
URL: https://github.com/apache/kafka/pull/19932#discussion_r2150304329
##
test-common/test-common-runtime/src/main/java/org/apache/kafka/common/test/KafkaClusterTestKit.java:
##
@@ -556,7 +556,7 @@ public String bootstrapServers() {
Yunyung commented on PR #19962:
URL: https://github.com/apache/kafka/pull/19962#issuecomment-2977114376
LGTM, please correct the Jira number in PR title.
--
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
Andrew Schofield created KAFKA-19410:
Summary: Validate alignment of subscribed topics and assigned
partitions in share consumer
Key: KAFKA-19410
URL: https://issues.apache.org/jira/browse/KAFKA-19410
chia7712 commented on code in PR #19932:
URL: https://github.com/apache/kafka/pull/19932#discussion_r2150303430
##
test-common/test-common-runtime/src/main/java/org/apache/kafka/common/test/KafkaClusterTestKit.java:
##
@@ -556,7 +556,7 @@ public String bootstrapServers() {
[
https://issues.apache.org/jira/browse/KAFKA-16778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans resolved KAFKA-16778.
Resolution: Fixed
This was fixed by moving all subscription state changes to the backgroun
jsancio commented on code in PR #19800:
URL: https://github.com/apache/kafka/pull/19800#discussion_r2150825590
##
raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java:
##
@@ -2882,6 +2908,7 @@ private FetchRequestData buildFetchRequest() {
.setLastFetch
[
https://issues.apache.org/jira/browse/KAFKA-19406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xuanzhang gong reassigned KAFKA-19406:
--
Assignee: xuanzhang gong (was: Chia-Ping Tsai)
> Remove BrokerTopicStats#removeOldFo
[
https://issues.apache.org/jira/browse/KAFKA-19406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17979552#comment-17979552
]
xuanzhang gong commented on KAFKA-19406:
hi [~chia7712]
I have fixed it. plz a
FrankYang0529 commented on code in PR #19975:
URL: https://github.com/apache/kafka/pull/19975#discussion_r2151426572
##
clients/src/test/java/org/apache/kafka/common/metrics/MetricsTest.java:
##
@@ -700,24 +681,15 @@ public void testMetricInstances() {
assertEquals(
[
https://issues.apache.org/jira/browse/KAFKA-19409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17978631#comment-17978631
]
Mahesh Sambaram commented on KAFKA-19409:
-
Hi[~mjsax] , I would like to contribu
chia7712 commented on PR #19968:
URL: https://github.com/apache/kafka/pull/19968#issuecomment-2975690837
@Rancho-7 could you please loop the test to ensure it is stable?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
[
https://issues.apache.org/jira/browse/KAFKA-19042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
黃竣陽 updated KAFKA-19042:
Description:
This is an umbrella Jira about moving integration tests from kafka.api module
to clients-integration
[
https://issues.apache.org/jira/browse/KAFKA-19368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17979258#comment-17979258
]
PoAn Yang commented on KAFKA-19368:
---
Discussion thread:
[https://lists.apache.org/thr
chia7712 commented on code in PR #19776:
URL: https://github.com/apache/kafka/pull/19776#discussion_r2150020977
##
server-common/src/test/java/org/apache/kafka/server/IntegrationTestUtils.java:
##
@@ -0,0 +1,87 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under on
[
https://issues.apache.org/jira/browse/KAFKA-19407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haruki Okada updated KAFKA-19407:
-
Description:
h2. Environment
* Kafka version: 3.3.2 (But we suppose this issue still exists in
m1a2st commented on code in PR #19527:
URL: https://github.com/apache/kafka/pull/19527#discussion_r2150148047
##
clients/src/main/java/org/apache/kafka/common/security/authenticator/LoginManager.java:
##
@@ -53,20 +56,30 @@ public class LoginManager {
// dynamic configs (br
ijuma commented on code in PR #19948:
URL: https://github.com/apache/kafka/pull/19948#discussion_r2150617216
##
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java:
##
@@ -1977,7 +1977,7 @@ public void
testOperationsBySubscribingConsumerWithDefaultGro
mumrah commented on code in PR #19800:
URL: https://github.com/apache/kafka/pull/19800#discussion_r2150719050
##
raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java:
##
@@ -1514,19 +1527,22 @@ private CompletableFuture
handleFetchRequest(
|| FetchResponse
ijuma commented on code in PR #19948:
URL: https://github.com/apache/kafka/pull/19948#discussion_r2150617216
##
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java:
##
@@ -1977,7 +1977,7 @@ public void
testOperationsBySubscribingConsumerWithDefaultGro
[
https://issues.apache.org/jira/browse/KAFKA-19409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17979262#comment-17979262
]
Bruno Cadonna commented on KAFKA-19409:
---
Look into these tickets:
https://issues.
[
https://issues.apache.org/jira/browse/KAFKA-15282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans resolved KAFKA-15282.
Resolution: Won't Fix
Closing as won't do as client-side assignors are not in scope for no
[
https://issues.apache.org/jira/browse/KAFKA-19393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-19393:
---
Labels: kip-848-client-support (was: )
> Consolidate consumer assignment state views
>
[
https://issues.apache.org/jira/browse/KAFKA-15279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans resolved KAFKA-15279.
Resolution: Won't Fix
Closing as won't do as client-side assignors are not in scope for no
[
https://issues.apache.org/jira/browse/KAFKA-19259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-19259:
---
Labels: consumer-threading-refactor (was: )
> Async consumer fetch intermittent delays on c
[
https://issues.apache.org/jira/browse/KAFKA-15307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17979278#comment-17979278
]
Mahesh Sambaram commented on KAFKA-15307:
-
Hi [~mjsax] , can i work on this
> K
[
https://issues.apache.org/jira/browse/KAFKA-18812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-18812:
---
Fix Version/s: 4.2.0
> Improve new consumer API errors upon background thread failures
> ---
[
https://issues.apache.org/jira/browse/KAFKA-18812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17979279#comment-17979279
]
Lianet Magrans commented on KAFKA-18812:
Hey [~frankvicky], is this something yo
FrankYang0529 commented on code in PR #19932:
URL: https://github.com/apache/kafka/pull/19932#discussion_r2150342733
##
test-common/test-common-runtime/src/main/java/org/apache/kafka/common/test/KafkaClusterTestKit.java:
##
@@ -556,7 +556,7 @@ public String bootstrapServers() {
jsancio commented on code in PR #19800:
URL: https://github.com/apache/kafka/pull/19800#discussion_r2150840804
##
raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java:
##
@@ -1514,19 +1527,22 @@ private CompletableFuture
handleFetchRequest(
|| FetchRespons
jsancio commented on code in PR #19800:
URL: https://github.com/apache/kafka/pull/19800#discussion_r2150833728
##
raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java:
##
@@ -386,6 +385,11 @@ private void onUpdateLeaderHighWatermark(
// records still held i
kirktrue commented on code in PR #19917:
URL: https://github.com/apache/kafka/pull/19917#discussion_r2150887174
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractFetch.java:
##
@@ -470,7 +475,19 @@ protected Map
prepareFetchRequests()
}
kirktrue commented on PR #17022:
URL: https://github.com/apache/kafka/pull/17022#issuecomment-2978134097
@jolshan @mjsax—Another ping to check if we can merge... Thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
[
https://issues.apache.org/jira/browse/KAFKA-19331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17979315#comment-17979315
]
Naman Kumar Singh commented on KAFKA-19331:
---
[~mingyen066] if you are not wor
davetroiano opened a new pull request, #19973:
URL: https://github.com/apache/kafka/pull/19973
PR prompted by discussion with @mjsax
Prior to this change, the doc for `min.insync.replicas` could have been
interpreted as being used to short-circuit in the `acks=all` case (e.g., see
th
mjsax commented on code in PR #19973:
URL: https://github.com/apache/kafka/pull/19973#discussion_r2150915147
##
clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java:
##
@@ -169,10 +169,13 @@ public class TopicConfig {
"to trigger the unclean leader ele
davetroiano commented on code in PR #19973:
URL: https://github.com/apache/kafka/pull/19973#discussion_r2150923369
##
clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java:
##
@@ -169,10 +169,13 @@ public class TopicConfig {
"to trigger the unclean lead
mjsax commented on code in PR #19973:
URL: https://github.com/apache/kafka/pull/19973#discussion_r2150915147
##
clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java:
##
@@ -169,10 +169,13 @@ public class TopicConfig {
"to trigger the unclean leader ele
kirktrue commented on code in PR #19917:
URL: https://github.com/apache/kafka/pull/19917#discussion_r2150942035
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractFetch.java:
##
@@ -470,7 +475,19 @@ protected Map
prepareFetchRequests()
}
kirktrue commented on code in PR #19917:
URL: https://github.com/apache/kafka/pull/19917#discussion_r2150942923
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java:
##
@@ -1135,7 +1134,9 @@ CompletableFuture
revokePartitions(Set p
kirktrue commented on code in PR #19917:
URL: https://github.com/apache/kafka/pull/19917#discussion_r2150944599
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/CompletableEventReaper.java:
##
@@ -166,9 +161,48 @@ public boolean contains(CompletableEve
kirktrue commented on code in PR #19917:
URL: https://github.com/apache/kafka/pull/19917#discussion_r2150949379
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/CompletableEventReaper.java:
##
@@ -166,9 +161,48 @@ public boolean contains(CompletableEve
kirktrue commented on code in PR #19917:
URL: https://github.com/apache/kafka/pull/19917#discussion_r2150944024
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventProcessor.java:
##
@@ -310,7 +311,9 @@ private void process(final Assignmen
kirktrue commented on code in PR #19917:
URL: https://github.com/apache/kafka/pull/19917#discussion_r2150942549
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerMembershipManager.java:
##
@@ -414,8 +413,8 @@ public CompletableFuture
signalPartitionsR
m1a2st commented on code in PR #19527:
URL: https://github.com/apache/kafka/pull/19527#discussion_r2150148047
##
clients/src/main/java/org/apache/kafka/common/security/authenticator/LoginManager.java:
##
@@ -53,20 +56,30 @@ public class LoginManager {
// dynamic configs (br
[
https://issues.apache.org/jira/browse/KAFKA-19409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17979236#comment-17979236
]
Mahesh Sambaram commented on KAFKA-19409:
-
[~cadonna] , thank you replying. Can
[
https://issues.apache.org/jira/browse/KAFKA-16870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17979233#comment-17979233
]
Ksolves India Limited commented on KAFKA-16870:
---
Hi [~gharris1727]
Can yo
chia7712 commented on code in PR #19527:
URL: https://github.com/apache/kafka/pull/19527#discussion_r2149989221
##
clients/src/main/java/org/apache/kafka/common/security/authenticator/LoginManager.java:
##
@@ -53,20 +56,30 @@ public class LoginManager {
// dynamic configs (
ocadaruma opened a new pull request, #19972:
URL: https://github.com/apache/kafka/pull/19972
## Summary
- Fix potential race condition in
LogSegment#readMaxTimestampAndOffsetSoFar(), which may result in non-monotonic
offsets and causes replication to stop.
- See https://issues.apache.
[
https://issues.apache.org/jira/browse/KAFKA-19410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17979268#comment-17979268
]
PoAn Yang commented on KAFKA-19410:
---
Hi Andrew, if you're not working on this, may I t
mjsax merged PR #19973:
URL: https://github.com/apache/kafka/pull/19973
--
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
mjsax commented on PR #19973:
URL: https://github.com/apache/kafka/pull/19973#issuecomment-2978661257
Thanks for the PR. Merged to `trunk` and cherry-picked to `4.1.` branch.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
rreddy-22 opened a new pull request, #19976:
URL: https://github.com/apache/kafka/pull/19976
This is a follow up to [https://github.com/apache/kafka/pull/19910](url)
`The coordinator failed to write an epoch fence transition for producer
jt142 to the transaction log with error COORDINATOR
github-actions[bot] commented on PR #19934:
URL: https://github.com/apache/kafka/pull/19934#issuecomment-2978805650
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 #19930:
URL: https://github.com/apache/kafka/pull/19930#issuecomment-2978805674
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-19407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17979322#comment-17979322
]
Haruki Okada commented on KAFKA-19407:
--
[~ijuma] [~chia7712]
Hi, I submitted [the
mjsax commented on code in PR #19973:
URL: https://github.com/apache/kafka/pull/19973#discussion_r2150929147
##
clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java:
##
@@ -169,10 +169,13 @@ public class TopicConfig {
"to trigger the unclean leader ele
[
https://issues.apache.org/jira/browse/KAFKA-18812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TengYao Chi reassigned KAFKA-18812:
---
Assignee: Lianet Magrans (was: TengYao Chi)
> Improve new consumer API errors upon backgro
[
https://issues.apache.org/jira/browse/KAFKA-18812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17979347#comment-17979347
]
TengYao Chi commented on KAFKA-18812:
-
As offline discussion, I have assigned to you
cmccabe commented on PR #19974:
URL: https://github.com/apache/kafka/pull/19974#issuecomment-2978488144
Thanks for this fix! One problem I see is that this will allow the deletion
to partly go through, until we run out of records. It would be better for the
deletion to fail completely or su
jsancio commented on code in PR #19800:
URL: https://github.com/apache/kafka/pull/19800#discussion_r2150841657
##
clients/src/main/resources/common/message/FetchRequest.json:
##
@@ -103,7 +105,10 @@
{ "name": "PartitionMaxBytes", "type": "int32", "versions": "0+",
ahuang98 opened a new pull request, #19974:
URL: https://github.com/apache/kafka/pull/19974
If there are more deletion filters after we initially hit the
`MAX_RECORDS_PER_USER_OP` bound, we will add an additional deletion record
ontop of that for each additional filter.
--
This is an aut
[
https://issues.apache.org/jira/browse/KAFKA-19410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
PoAn Yang reassigned KAFKA-19410:
-
Assignee: PoAn Yang
> Validate alignment of subscribed topics and assigned partitions in share
DL1231 opened a new pull request, #19975:
URL: https://github.com/apache/kafka/pull/19975
see https://github.com/apache/kafka/pull/19948#discussion_r2150617216,
replace test "catch exception" by assertThrows.
--
This is an automated message from the Apache Git Service.
To respond to t
jolshan commented on code in PR #17022:
URL: https://github.com/apache/kafka/pull/17022#discussion_r2151075013
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -779,14 +779,25 @@ public synchronized void
maybeTransitionToErrorS
[
https://issues.apache.org/jira/browse/KAFKA-19331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17979354#comment-17979354
]
Ming-Yen Chung commented on KAFKA-19331:
[~naman_singh] Sorry, I’ve already revi
github-actions[bot] commented on PR #19203:
URL: https://github.com/apache/kafka/pull/19203#issuecomment-2978828856
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
[
https://issues.apache.org/jira/browse/KAFKA-19406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17979356#comment-17979356
]
Jimmy Wang commented on KAFKA-19406:
Hi [~chia7712] ,
I could help with this issue
[
https://issues.apache.org/jira/browse/KAFKA-19411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alyssa Huang reassigned KAFKA-19411:
Assignee: Alyssa Huang
> Delete ACLs records can exceed max records per user op
> ---
Alyssa Huang created KAFKA-19411:
Summary: Delete ACLs records can exceed max records per user op
Key: KAFKA-19411
URL: https://issues.apache.org/jira/browse/KAFKA-19411
Project: Kafka
Issue
gongxuanzhang commented on PR #18683:
URL: https://github.com/apache/kafka/pull/18683#issuecomment-2978633312
@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-15307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17979339#comment-17979339
]
Matthias J. Sax commented on KAFKA-15307:
-
Thanks for you interest. Assigned the
[
https://issues.apache.org/jira/browse/KAFKA-15307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-15307:
---
Assignee: Mahesh Sambaram
> Kafka Streams configuration docs outdated
> ---
github-actions[bot] commented on PR #19186:
URL: https://github.com/apache/kafka/pull/19186#issuecomment-2978828826
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
[
https://issues.apache.org/jira/browse/KAFKA-19406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17979551#comment-17979551
]
Chia-Ping Tsai commented on KAFKA-19406:
The PR is ready :)
https://github.com/
97 matches
Mail list logo