frankvicky commented on PR #16319:
URL: https://github.com/apache/kafka/pull/16319#issuecomment-2164695371
Hi @showuon, I have refactor the test case by utilizing `@CsvSource`, PTAL
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
FrankYang0529 commented on PR #16254:
URL: https://github.com/apache/kafka/pull/16254#issuecomment-2164633695
Hi @chia7712, I addressed all comments. May you take a look? Thank you.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
FrankYang0529 commented on code in PR #16254:
URL: https://github.com/apache/kafka/pull/16254#discussion_r1637632275
##
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregateTest.java:
##
@@ -87,48 +85,45 @@
import static org.hamcrest.Cor
[
https://issues.apache.org/jira/browse/KAFKA-16901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-16901.
Fix Version/s: 3.9.0
Resolution: Fixed
> add unit tests for ConsumerRecords#records
chia7712 merged PR #16227:
URL: https://github.com/apache/kafka/pull/16227
--
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
gongxuanzhang commented on PR #16298:
URL: https://github.com/apache/kafka/pull/16298#issuecomment-2164609081
> @gongxuanzhang please add `spotlessJava.dependsOn 'processMessages'` to
the module having `processMessages` task. Otherwise, spotless may ignore those
generated code
I upda
chia7712 merged PR #16304:
URL: https://github.com/apache/kafka/pull/16304
--
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
Nancy-ksolves commented on code in PR #16295:
URL: https://github.com/apache/kafka/pull/16295#discussion_r1637621152
##
build.gradle:
##
@@ -46,7 +46,7 @@ plugins {
id 'org.scoverage' version '8.0.3' apply false
// Updating the shadow plugin version to 8.1.1 causes issue w
dengziming commented on code in PR #16230:
URL: https://github.com/apache/kafka/pull/16230#discussion_r1637473020
##
metadata/src/main/java/org/apache/kafka/metadata/bootstrap/BootstrapMetadata.java:
##
@@ -116,6 +139,34 @@ public BootstrapMetadata copyWithOnlyVersion() {
frankvicky commented on code in PR #16319:
URL: https://github.com/apache/kafka/pull/16319#discussion_r1637598927
##
clients/src/test/java/org/apache/kafka/common/utils/UtilsTest.java:
##
@@ -113,16 +113,26 @@ public void testGetHost() {
assertEquals("mydomain.com", get
superhx commented on PR #16206:
URL: https://github.com/apache/kafka/pull/16206#issuecomment-2164505170
@showuon Could you review this PR?
--
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 spec
showuon commented on code in PR #16319:
URL: https://github.com/apache/kafka/pull/16319#discussion_r1637590625
##
clients/src/test/java/org/apache/kafka/common/utils/UtilsTest.java:
##
@@ -113,16 +113,26 @@ public void testGetHost() {
assertEquals("mydomain.com", getHos
showuon commented on code in PR #16319:
URL: https://github.com/apache/kafka/pull/16319#discussion_r1637590625
##
clients/src/test/java/org/apache/kafka/common/utils/UtilsTest.java:
##
@@ -113,16 +113,26 @@ public void testGetHost() {
assertEquals("mydomain.com", getHos
adixitconfluent commented on code in PR #16274:
URL: https://github.com/apache/kafka/pull/16274#discussion_r1637579381
##
core/src/main/java/kafka/server/SharePartition.java:
##
@@ -310,126 +485,361 @@ private void initialize() {
// TODO: Provide implementation to initi
adixitconfluent commented on code in PR #16274:
URL: https://github.com/apache/kafka/pull/16274#discussion_r1637574165
##
core/src/main/java/kafka/server/SharePartition.java:
##
@@ -54,6 +60,7 @@ public class SharePartition {
* The state of the records determines if the re
kamalcph commented on PR #16321:
URL: https://github.com/apache/kafka/pull/16321#issuecomment-2164410837
@dopuskh3
Call for review. 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 s
kamalcph opened a new pull request, #16321:
URL: https://github.com/apache/kafka/pull/16321
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade note
Kamal Chandraprakash created KAFKA-16948:
Summary: Reset tier lag metrics on becoming follower
Key: KAFKA-16948
URL: https://issues.apache.org/jira/browse/KAFKA-16948
Project: Kafka
I
adixitconfluent commented on code in PR #16263:
URL: https://github.com/apache/kafka/pull/16263#discussion_r1637556905
##
core/src/test/java/kafka/server/share/SharePartitionManagerTest.java:
##
@@ -0,0 +1,916 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
adixitconfluent commented on code in PR #16263:
URL: https://github.com/apache/kafka/pull/16263#discussion_r1637549886
##
core/src/main/java/kafka/server/share/SharePartitionManager.java:
##
@@ -0,0 +1,418 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
xiaoqingwanga commented on PR #16303:
URL: https://github.com/apache/kafka/pull/16303#issuecomment-2164374450
@gharris1727 Thank you very much for your suggestion! I have made another
commit, resolving the issue mentioned above.
--
This is an automated message from the Apache Git Service.
apourchet closed pull request #16314: KAFKA-15045: (KIP-924 pt. 24) Correct
stateful task flagging
URL: https://github.com/apache/kafka/pull/16314
--
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
kamalcph opened a new pull request, #16320:
URL: https://github.com/apache/kafka/pull/16320
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade
C0urante merged PR #16306:
URL: https://github.com/apache/kafka/pull/16306
--
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
github-actions[bot] commented on PR #15188:
URL: https://github.com/apache/kafka/pull/15188#issuecomment-2164295049
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 ask a committer for
review. If the PR has merge
showuon commented on PR #16211:
URL: https://github.com/apache/kafka/pull/16211#issuecomment-2164292176
@chia7712 , thanks for the review. PR updated in this commit:
https://github.com/apache/kafka/pull/16211/commits/7db45c2e8f08b4a381717b4c6b7f466bd116cd4e
. Thanks.
--
This is an automa
showuon commented on code in PR #16211:
URL: https://github.com/apache/kafka/pull/16211#discussion_r1637455856
##
raft/src/main/java/org/apache/kafka/raft/LeaderState.java:
##
@@ -126,8 +127,13 @@ public long timeUntilCheckQuorumExpires(long
currentTimeMs) {
*/
publi
showuon commented on code in PR #16211:
URL: https://github.com/apache/kafka/pull/16211#discussion_r1637455387
##
raft/src/main/java/org/apache/kafka/raft/LeaderState.java:
##
@@ -111,9 +111,10 @@ public long timeUntilCheckQuorumExpires(long
currentTimeMs) {
long remai
[
https://issues.apache.org/jira/browse/KAFKA-12480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854611#comment-17854611
]
Ivan Yurchenko commented on KAFKA-12480:
With
[KIP-899|https://cwiki.apache.org
[
https://issues.apache.org/jira/browse/KAFKA-13467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854612#comment-17854612
]
Ivan Yurchenko commented on KAFKA-13467:
With
[KIP-899|https://cwiki.apache.org
[
https://issues.apache.org/jira/browse/KAFKA-16781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854610#comment-17854610
]
TengYao Chi commented on KAFKA-16781:
-
Hi [~tinaselenge] feel free to take this if y
[
https://issues.apache.org/jira/browse/KAFKA-14507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dujian0068 reassigned KAFKA-14507:
--
Assignee: dujian0068
> Add ConsumerGroupPrepareAssignment API
> -
[
https://issues.apache.org/jira/browse/KAFKA-14705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dujian0068 reassigned KAFKA-14705:
--
Assignee: dujian0068
> Remove deprecated options and redirections
> -
[
https://issues.apache.org/jira/browse/KAFKA-16941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854604#comment-17854604
]
Lin Siyuan commented on KAFKA-16941:
I'm a newbie and I will do my best to find the
frankvicky commented on PR #16319:
URL: https://github.com/apache/kafka/pull/16319#issuecomment-2164259901
Hi @zhaochun-ma, @showuon
I have fix the bug that regex can't correctly parse that connection string
starting with `SASL_PLAINTEXT`. PTAL 😄
Special thanks to @zhaochun-ma findin
frankvicky opened a new pull request, #16319:
URL: https://github.com/apache/kafka/pull/16319
In previous PR(#16048), I mistakenly excluded the underscore (_) from the
set of valid characters for the protocol, resulting in the inability to
correctly parse the connection string for SASL_PLAI
[
https://issues.apache.org/jira/browse/KAFKA-16913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854601#comment-17854601
]
Ganesh Sadanala commented on KAFKA-16913:
-
is there any documentation to be upda
[
https://issues.apache.org/jira/browse/KAFKA-16913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854600#comment-17854600
]
Ganesh Sadanala commented on KAFKA-16913:
-
PR is ready to review
> Support exte
kirktrue commented on PR #16310:
URL: https://github.com/apache/kafka/pull/16310#issuecomment-2164238647
@AndrewJSchofield @cadonna @lianetm @philipnee—please review this PR. It's
an alternative take on #16241 that seems simpler and not fraught with peril.
Thanks!
--
This is an aut
kirktrue commented on code in PR #16310:
URL: https://github.com/apache/kafka/pull/16310#discussion_r1637405808
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -1983,6 +2009,10 @@ SubscriptionState subscriptions() {
re
apourchet opened a new pull request, #16318:
URL: https://github.com/apache/kafka/pull/16318
Since the new public API for TaskAssignor shared a name, this rename will
prevent users from confusing the internal definition with the public one.
### Committer Checklist (excluded from commi
gongxuanzhang commented on PR #16278:
URL: https://github.com/apache/kafka/pull/16278#issuecomment-2164215470
> @gongxuanzhang you need to fix it again :)
Ok,I'll fix it periodically before merging
--
This is an automated message from the Apache Git Service.
To respond to the messag
chia7712 commented on code in PR #16167:
URL: https://github.com/apache/kafka/pull/16167#discussion_r1637373367
##
storage/src/test/java/org/apache/kafka/storage/internals/log/LogValidatorTest.java:
##
@@ -0,0 +1,2100 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) u
gongxuanzhang commented on code in PR #16277:
URL: https://github.com/apache/kafka/pull/16277#discussion_r1637379530
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java:
##
@@ -1033,10 +1033,18 @@ public Deque getDeque(TopicPartition tp)
[
https://issues.apache.org/jira/browse/KAFKA-16946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854595#comment-17854595
]
Luke Chen commented on KAFKA-16946:
---
[~frankvicky] , this is a blocker for v3.8.0. Hop
[
https://issues.apache.org/jira/browse/KAFKA-16946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-16946:
--
Fix Version/s: 3.8.0
> Utils.getHost/getPort cannot parse SASL_PLAINTEXT://host:port
> ---
m1a2st opened a new pull request, #16317:
URL: https://github.com/apache/kafka/pull/16317
https://issues.apache.org/jira/browse/KAFKA-16939
some secnario is wrong, so fix it
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
gongxuanzhang commented on PR #16305:
URL: https://github.com/apache/kafka/pull/16305#issuecomment-2164206281
I agree, with the development of Java, the performance of ConcurrentHashMap
has indeed significantly improved
--
This is an automated message from the Apache Git Service.
To respo
mjsax commented on code in PR #16316:
URL: https://github.com/apache/kafka/pull/16316#discussion_r1637372406
##
docs/streams/upgrade-guide.html:
##
@@ -303,6 +303,62 @@ Streams API
adds a new config default.client.supplier that allows to
use a custom KafkaClientSupplier
mjsax opened a new pull request, #16316:
URL: https://github.com/apache/kafka/pull/16316
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of testing s
chia7712 commented on PR #16231:
URL: https://github.com/apache/kafka/pull/16231#issuecomment-2164203749
@brandboat could you please remove `Microbenchmarks` from suppression file?
https://github.com/apache/kafka/blob/6d1f8f8727e8f9c7071b83b7dd9feb840d8d661f/checkstyle/suppressions.xm
philipnee commented on code in PR #16310:
URL: https://github.com/apache/kafka/pull/16310#discussion_r1637370335
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -1983,6 +2009,10 @@ SubscriptionState subscriptions() {
r
[
https://issues.apache.org/jira/browse/KAFKA-16938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-16938.
Resolution: Fixed
> non-dynamic props gets corrupted due to circular reference between
>
[
https://issues.apache.org/jira/browse/KAFKA-16944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854593#comment-17854593
]
dujian0068 commented on KAFKA-16944:
Hello, does this problem need to be fixed quick
chia7712 merged PR #16302:
URL: https://github.com/apache/kafka/pull/16302
--
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-16946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854591#comment-17854591
]
Luke Chen commented on KAFKA-16946:
---
Go ahead to fix it, [~frankvicky] !
> Utils.getH
[
https://issues.apache.org/jira/browse/KAFKA-16946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen reassigned KAFKA-16946:
-
Assignee: TengYao Chi
> Utils.getHost/getPort cannot parse SASL_PLAINTEXT://host:port
> ---
chia7712 merged PR #16285:
URL: https://github.com/apache/kafka/pull/16285
--
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
cmccabe commented on PR #16048:
URL: https://github.com/apache/kafka/pull/16048#issuecomment-2164187718
> @frankvicky looks like with this change, SASL_PLAINTEXT://localhost:50132
becomes invalid url because of _ in the protocol, and it's a breaking change,
is this expected?
definite
TaiJuWu commented on PR #16167:
URL: https://github.com/apache/kafka/pull/16167#issuecomment-2164170657
@chia7712 Please take look! Thanks.
--
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
ableegoldman commented on code in PR #16265:
URL: https://github.com/apache/kafka/pull/16265#discussion_r1637334663
##
docs/streams/developer-guide/config-streams.html:
##
@@ -441,8 +441,8 @@ num.standby.replicastask.assignor.class
Medium
-A task assigno
kirktrue commented on PR #16241:
URL: https://github.com/apache/kafka/pull/16241#issuecomment-2164161606
@lianetm @cadonna @AndrewJSchofield—PTAL at an alternate implementation of
this Jira: #16310. Thanks!
--
This is an automated message from the Apache Git Service.
To respond to the mes
[
https://issues.apache.org/jira/browse/KAFKA-13560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana updated KAFKA-13560:
---
Fix Version/s: 3.9.0
(was: 3.8.0)
> Load indexes and data in async ma
[
https://issues.apache.org/jira/browse/KAFKA-15300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana updated KAFKA-15300:
---
Fix Version/s: 3.9.0
(was: 3.8.0)
> Include remotelog size in complet
[
https://issues.apache.org/jira/browse/KAFKA-15480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana updated KAFKA-15480:
---
Fix Version/s: 3.9.0
(was: 3.8.0)
> Add RemoteStorageInterruptedExcep
[
https://issues.apache.org/jira/browse/KAFKA-15214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana updated KAFKA-15214:
---
Fix Version/s: 3.9.0
(was: 3.8.0)
> Add metrics for OffsetOutOfRangeE
[
https://issues.apache.org/jira/browse/KAFKA-15529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana updated KAFKA-15529:
---
Fix Version/s: 3.9.0
(was: 3.8.0)
> Flaky test ReassignReplicaShrinkT
[
https://issues.apache.org/jira/browse/KAFKA-15038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana updated KAFKA-15038:
---
Fix Version/s: 3.9.0
(was: 3.8.0)
> Use topic id/name mapping from th
[
https://issues.apache.org/jira/browse/KAFKA-16946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854582#comment-17854582
]
TengYao Chi commented on KAFKA-16946:
-
Hi [~showuon] , if the issue finder is not wi
[
https://issues.apache.org/jira/browse/KAFKA-9578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana updated KAFKA-9578:
--
Fix Version/s: 3.9.0
(was: 3.8.0)
> Kafka Tiered Storage - System Tests
[
https://issues.apache.org/jira/browse/KAFKA-15132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana updated KAFKA-15132:
---
Fix Version/s: 3.9.0
(was: 3.8.0)
> Implement disable & re-enablement
[
https://issues.apache.org/jira/browse/KAFKA-15376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana updated KAFKA-15376:
---
Fix Version/s: 3.9.0
(was: 3.8.0)
> Explore options of removing data
[
https://issues.apache.org/jira/browse/KAFKA-15864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana updated KAFKA-15864:
---
Fix Version/s: 3.9.0
(was: 3.8.0)
> Add more tests asserting the log-
[
https://issues.apache.org/jira/browse/KAFKA-15094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana updated KAFKA-15094:
---
Fix Version/s: 3.9.0
(was: 3.8.0)
> Add RemoteIndexCache metrics like
[
https://issues.apache.org/jira/browse/KAFKA-14915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana updated KAFKA-14915:
---
Fix Version/s: 3.9.0
(was: 3.8.0)
> Option to consume multiple partit
[
https://issues.apache.org/jira/browse/KAFKA-15195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana updated KAFKA-15195:
---
Fix Version/s: 3.9.0
(was: 3.8.0)
> Regenerate segment-aligned produc
[
https://issues.apache.org/jira/browse/KAFKA-15301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana updated KAFKA-15301:
---
Fix Version/s: 3.9.0
(was: 3.8.0)
> [Tiered Storage] Historically com
[
https://issues.apache.org/jira/browse/KAFKA-15341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana updated KAFKA-15341:
---
Fix Version/s: 3.9.0
(was: 3.8.0)
> Enabling TS for a topic during ro
[
https://issues.apache.org/jira/browse/KAFKA-13355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana updated KAFKA-13355:
---
Fix Version/s: 3.9.0
(was: 3.8.0)
> Shutdown broker eventually when u
[
https://issues.apache.org/jira/browse/KAFKA-15969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana updated KAFKA-15969:
---
Fix Version/s: 3.9.0
(was: 3.8.0)
> Align RemoteStorageThreadPool met
[
https://issues.apache.org/jira/browse/KAFKA-15331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana updated KAFKA-15331:
---
Fix Version/s: 3.9.0
(was: 3.8.0)
> Handle remote log enabled topic d
[
https://issues.apache.org/jira/browse/KAFKA-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana updated KAFKA-15388:
---
Fix Version/s: 3.9.0
(was: 3.8.0)
> Handle topics that were having co
frankvicky commented on code in PR #16250:
URL: https://github.com/apache/kafka/pull/16250#discussion_r1637320049
##
clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java:
##
@@ -1988,6 +1989,15 @@ public void testDescribeClientMetricsConfigs() throws
E
frankvicky commented on PR #16048:
URL: https://github.com/apache/kafka/pull/16048#issuecomment-2164151022
Hi @zhaochun-ma
Thanks for your remind 😄
If you have free cycle, it would be nice you could have a PR to fix it
--
This is an automated message from the Apache Git Service.
To
zhaochun-ma commented on PR #16048:
URL: https://github.com/apache/kafka/pull/16048#issuecomment-2164138119
> @zhaochun-ma , nice find! I've created
[KAFKA-16946](https://issues.apache.org/jira/browse/KAFKA-16946) for this
issue. Are you interested in opening a PR to fix it?
i haven'
xiaoqingwanga commented on PR #16303:
URL: https://github.com/apache/kafka/pull/16303#issuecomment-2164138080
@gharris1727 Thanks for the tip! I'll look into it and tweak the code a bit.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on t
[
https://issues.apache.org/jira/browse/KAFKA-14877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854579#comment-17854579
]
Satish Duggana commented on KAFKA-14877:
InMemoryLeaderEpochCheckpoint seems to
[
https://issues.apache.org/jira/browse/KAFKA-14877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana resolved KAFKA-14877.
Resolution: Invalid
> refactor InMemoryLeaderEpochCheckpoint
> ---
[
https://issues.apache.org/jira/browse/KAFKA-16935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton resolved KAFKA-16935.
---
Resolution: Fixed
> Automatically wait for cluster startup in embedded Connect integration t
[
https://issues.apache.org/jira/browse/KAFKA-16935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton reopened KAFKA-16935:
---
> Automatically wait for cluster startup in embedded Connect integration tests
> ---
[
https://issues.apache.org/jira/browse/KAFKA-16935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-16935:
--
Fix Version/s: 3.8.0
> Automatically wait for cluster startup in embedded Connect integration
C0urante merged PR #16288:
URL: https://github.com/apache/kafka/pull/16288
--
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-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana updated KAFKA-16947:
---
Fix Version/s: 3.9.0
(was: 3.8.0)
> Kafka Tiered Storage V2
> ---
[
https://issues.apache.org/jira/browse/KAFKA-13561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-13561.
-
Resolution: Duplicate
> Consider deprecating `StreamsBuilder#build(props)` function
> --
[
https://issues.apache.org/jira/browse/KAFKA-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana updated KAFKA-16947:
---
Affects Version/s: (was: 3.6.0)
> Kafka Tiered Storage V2
> ---
>
>
Satish Duggana created KAFKA-16947:
--
Summary: Kafka Tiered Storage V2
Key: KAFKA-16947
URL: https://issues.apache.org/jira/browse/KAFKA-16947
Project: Kafka
Issue Type: Improvement
Affec
[
https://issues.apache.org/jira/browse/KAFKA-16945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854578#comment-17854578
]
Matthias J. Sax commented on KAFKA-16945:
-
I did not look... :P
Found https://i
[
https://issues.apache.org/jira/browse/KAFKA-16890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana resolved KAFKA-16890.
Resolution: Fixed
> Failing to build aux state on broker failover
> --
[
https://issues.apache.org/jira/browse/KAFKA-16925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854577#comment-17854577
]
Matthias J. Sax commented on KAFKA-16925:
-
{quote}My understanding is that the p
showuon commented on PR #16048:
URL: https://github.com/apache/kafka/pull/16048#issuecomment-2164106388
@zhaochun-ma , nice find! I've created
[KAFKA-16946](https://issues.apache.org/jira/browse/KAFKA-16946) for this
issue. Are you interested in opening a PR to fix it?
--
This is an auto
1 - 100 of 300 matches
Mail list logo
