[
https://issues.apache.org/jira/browse/KAFKA-17859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
thanhnd1996 updated KAFKA-17859:
Attachment: (was: Alert-ERROR-Elasticsearch.png)
> Bug
> ---
>
> Key: KAFKA-17
[
https://issues.apache.org/jira/browse/KAFKA-17859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
thanhnd1996 updated KAFKA-17859:
Attachment: (was: failed-producer-init-from-service.png)
> Bug
> ---
>
> Key:
thanhnd1996 created KAFKA-17859:
---
Summary: Bug
Key: KAFKA-17859
URL: https://issues.apache.org/jira/browse/KAFKA-17859
Project: Kafka
Issue Type: Bug
Components: controller
Affect
fvaleri commented on code in PR #17575:
URL: https://github.com/apache/kafka/pull/17575#discussion_r1811944283
##
storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerConfig.java:
##
@@ -104,7 +104,7 @@ public final class RemoteLogManagerConfig {
showuon commented on code in PR #17575:
URL: https://github.com/apache/kafka/pull/17575#discussion_r1811933891
##
storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerConfig.java:
##
@@ -104,7 +104,7 @@ public final class RemoteLogManagerConfig {
satishd commented on code in PR #17575:
URL: https://github.com/apache/kafka/pull/17575#discussion_r1811927922
##
storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerConfig.java:
##
@@ -104,7 +104,7 @@ public final class RemoteLogManagerConfig {
TaiJuWu opened a new pull request, #17584:
URL: https://github.com/apache/kafka/pull/17584
jira: https://issues.apache.org/jira/browse/KAFKA-16966
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI buil
fvaleri commented on code in PR #17575:
URL: https://github.com/apache/kafka/pull/17575#discussion_r1811918428
##
storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerConfig.java:
##
@@ -104,7 +104,7 @@ public final class RemoteLogManagerConfig {
adixitconfluent commented on code in PR #17583:
URL: https://github.com/apache/kafka/pull/17583#discussion_r1811860775
##
core/src/main/java/kafka/server/share/DelayedShareFetch.java:
##
@@ -79,16 +79,16 @@ public void onExpiration() {
*/
@Override
public void on
frankvicky commented on PR #17373:
URL: https://github.com/apache/kafka/pull/17373#issuecomment-2430832465
> > About zk stuff, I'm think about removing the zk configurations might be
better handled as a follow-up PR. WDYT?
>
> Sounds good to me. But if we decided to remove them later,
TengYao Chi created KAFKA-17858:
---
Summary: Remove ZK-related configuration from the log4j
configuration.
Key: KAFKA-17858
URL: https://issues.apache.org/jira/browse/KAFKA-17858
Project: Kafka
showuon commented on code in PR #17373:
URL: https://github.com/apache/kafka/pull/17373#discussion_r1811789962
##
config/connect-log4j2.properties:
##
@@ -0,0 +1,39 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See t
frankvicky commented on code in PR #17373:
URL: https://github.com/apache/kafka/pull/17373#discussion_r1811787630
##
build.gradle:
##
@@ -167,8 +167,10 @@ allprojects {
// ZooKeeper (potentially older and containing CVEs)
libs.nettyHandler,
libs.
showuon commented on PR #17373:
URL: https://github.com/apache/kafka/pull/17373#issuecomment-2430811748
> About zk stuff, I'm think about removing the zk configurations might be
better handled as a follow-up PR. WDYT?
Sounds good to me. But if we decided to remove them later, please o
showuon commented on code in PR #17373:
URL: https://github.com/apache/kafka/pull/17373#discussion_r1811786044
##
build.gradle:
##
@@ -167,8 +167,10 @@ allprojects {
// ZooKeeper (potentially older and containing CVEs)
libs.nettyHandler,
libs.net
showuon commented on code in PR #17511:
URL: https://github.com/apache/kafka/pull/17511#discussion_r1811781412
##
clients/src/main/java/org/apache/kafka/common/internals/Plugin.java:
##
@@ -0,0 +1,78 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+
ChengyanOo commented on PR #17507:
URL: https://github.com/apache/kafka/pull/17507#issuecomment-2430802741
> There's a spotless failure:
https://github.com/apache/kafka/actions/runs/11431595728/job/31800811677?pr=17507,
can you fix it?
Sorry I was sick for the past couple of days, I'
showuon commented on code in PR #17511:
URL: https://github.com/apache/kafka/pull/17511#discussion_r1811774020
##
clients/src/test/java/org/apache/kafka/common/internals/PluginTest.java:
##
@@ -0,0 +1,124 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or m
showuon commented on code in PR #17575:
URL: https://github.com/apache/kafka/pull/17575#discussion_r1811764255
##
storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerConfig.java:
##
@@ -104,7 +104,7 @@ public final class RemoteLogManagerConfig {
showuon commented on code in PR #17575:
URL: https://github.com/apache/kafka/pull/17575#discussion_r1811764255
##
storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerConfig.java:
##
@@ -104,7 +104,7 @@ public final class RemoteLogManagerConfig {
clarkwtc commented on code in PR #17578:
URL: https://github.com/apache/kafka/pull/17578#discussion_r1811683401
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java:
##
@@ -707,7 +708,8 @@ private Optional>
createPushRequest(ClientTe
clarkwtc commented on code in PR #17570:
URL: https://github.com/apache/kafka/pull/17570#discussion_r1811669532
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java:
##
@@ -337,33 +336,33 @@ public long timeToNextUpdate(long requestTi
[
https://issues.apache.org/jira/browse/KAFKA-17804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892027#comment-17892027
]
kangning.li edited comment on KAFKA-17804 at 10/23/24 2:04 AM:
---
[
https://issues.apache.org/jira/browse/KAFKA-17804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892027#comment-17892027
]
kangning.li edited comment on KAFKA-17804 at 10/23/24 2:04 AM:
---
[
https://issues.apache.org/jira/browse/KAFKA-17804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892027#comment-17892027
]
kangning.li edited comment on KAFKA-17804 at 10/23/24 2:02 AM:
---
[
https://issues.apache.org/jira/browse/KAFKA-17804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892027#comment-17892027
]
kangning.li edited comment on KAFKA-17804 at 10/23/24 2:01 AM:
---
[
https://issues.apache.org/jira/browse/KAFKA-17804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892027#comment-17892027
]
kangning.li edited comment on KAFKA-17804 at 10/23/24 2:01 AM:
---
[
https://issues.apache.org/jira/browse/KAFKA-17804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892027#comment-17892027
]
kangning.li commented on KAFKA-17804:
-
Hi [~junrao] , I have some thoughts on this i
[
https://issues.apache.org/jira/browse/KAFKA-15284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892018#comment-17892018
]
PoAn Yang commented on KAFKA-15284:
---
Hi [~kirktrue], I saw you reopen this issue. Is a
[
https://issues.apache.org/jira/browse/KAFKA-17857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892017#comment-17892017
]
Kuan Po Tseng commented on KAFKA-17857:
---
gentle ping [~gharris1727] , can I take o
jolshan commented on PR #17576:
URL: https://github.com/apache/kafka/pull/17576#issuecomment-2430540041
I wasn't sure if there would be any incompatibilities if we drop older java
versions with some of the older versions of Kafka used in the tests. But I
suppose if we do see issues, maybe w
cshannon commented on code in PR #16754:
URL: https://github.com/apache/kafka/pull/16754#discussion_r1811569693
##
build.gradle:
##
@@ -318,6 +318,18 @@ subprojects {
options.compilerArgs << "-Werror"
options.release = minJavaVersion
addParametersForTests(name, op
apoorvmittal10 commented on code in PR #17021:
URL: https://github.com/apache/kafka/pull/17021#discussion_r1811538931
##
build.gradle:
##
@@ -2638,6 +2638,7 @@ project(':streams') {
testImplementation libs.mockitoCore
testImplementation libs.mockitoJunitJupiter // supp
apoorvmittal10 commented on PR #17583:
URL: https://github.com/apache/kafka/pull/17583#issuecomment-2430488262
@junrao For my understanding, what can trigger `onComplete` without invoking
`tryComplete`? Is it the number of requests that can be in purgatory? I was
doing 10 share consumers pa
apoorvmittal10 commented on code in PR #17322:
URL: https://github.com/apache/kafka/pull/17322#discussion_r1811547391
##
core/src/main/java/kafka/server/share/SharePartition.java:
##
@@ -1138,6 +1185,7 @@ private void acquireSubsetBatchRecords(
} finally {
apoorvmittal10 commented on code in PR #17322:
URL: https://github.com/apache/kafka/pull/17322#discussion_r1811547391
##
core/src/main/java/kafka/server/share/SharePartition.java:
##
@@ -1138,6 +1185,7 @@ private void acquireSubsetBatchRecords(
} finally {
cmccabe commented on code in PR #17502:
URL: https://github.com/apache/kafka/pull/17502#discussion_r1811535659
##
metadata/src/main/java/org/apache/kafka/controller/PeriodicTaskControlManager.java:
##
@@ -0,0 +1,229 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) und
cmccabe commented on code in PR #17502:
URL: https://github.com/apache/kafka/pull/17502#discussion_r1811535659
##
metadata/src/main/java/org/apache/kafka/controller/PeriodicTaskControlManager.java:
##
@@ -0,0 +1,229 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) und
cmccabe commented on code in PR #17502:
URL: https://github.com/apache/kafka/pull/17502#discussion_r1811528276
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -1159,255 +1176,12 @@ void renounce() {
newWrongControllerExcept
cmccabe commented on code in PR #17502:
URL: https://github.com/apache/kafka/pull/17502#discussion_r1811528002
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -1855,6 +1633,97 @@ private QuorumController(
this.raftClient.register(metaL
cmccabe commented on code in PR #17502:
URL: https://github.com/apache/kafka/pull/17502#discussion_r1811524670
##
metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java:
##
@@ -1597,18 +1597,34 @@ public ControllerResult unregisterBroker(int
brokerId)
cmccabe commented on code in PR #17502:
URL: https://github.com/apache/kafka/pull/17502#discussion_r1811523833
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -1855,6 +1633,97 @@ private QuorumController(
this.raftClient.register(metaL
fonsdant commented on PR #17038:
URL: https://github.com/apache/kafka/pull/17038#issuecomment-2430443231
Thanks, @mimaison! 😄
--
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
cmccabe commented on code in PR #17502:
URL: https://github.com/apache/kafka/pull/17502#discussion_r1811521396
##
metadata/src/main/java/org/apache/kafka/controller/BrokerHeartbeatManager.java:
##
@@ -82,23 +80,16 @@ static class BrokerHeartbeatState {
*/
priv
apoorvmittal10 opened a new pull request, #17583:
URL: https://github.com/apache/kafka/pull/17583
The test shows that with 16 topic partitions reading 1 million messages with
10 Share Consumers, the share fetch stucks.
Though the code should execute `tryComplete` but in some scenario
[
https://issues.apache.org/jira/browse/KAFKA-17848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal reassigned KAFKA-17848:
-
Assignee: Apoorv Mittal (was: Abhinav Dixit)
> Resolve reliability issue on the broker
mumrah commented on code in PR #17502:
URL: https://github.com/apache/kafka/pull/17502#discussion_r1811413417
##
metadata/src/main/java/org/apache/kafka/controller/PeriodicTaskControlManager.java:
##
@@ -0,0 +1,229 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) unde
apoorvmittal10 commented on PR #17322:
URL: https://github.com/apache/kafka/pull/17322#issuecomment-2430251355
@chia7712 I have addressed the comments. Thanks for the review.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
apoorvmittal10 commented on code in PR #17322:
URL: https://github.com/apache/kafka/pull/17322#discussion_r1811377602
##
core/src/main/java/kafka/server/share/SharePartition.java:
##
@@ -1658,6 +1706,26 @@ private long findLastOffsetAcknowledged() {
return lastOffsetAck
chia7712 commented on code in PR #17322:
URL: https://github.com/apache/kafka/pull/17322#discussion_r1811465882
##
core/src/main/java/kafka/server/share/SharePartition.java:
##
@@ -1138,6 +1185,7 @@ private void acquireSubsetBatchRecords(
} finally {
lock.w
[
https://issues.apache.org/jira/browse/KAFKA-17854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-17854:
Component/s: streams
unit tests
> add tests for `ReadOnlyWindowStoreStub#
[
https://issues.apache.org/jira/browse/KAFKA-17857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris updated KAFKA-17857:
Labels: newbie (was: )
> Move AbstractResetIntegrationTest and subclasses to tools
>
gharris1727 commented on code in PR #16754:
URL: https://github.com/apache/kafka/pull/16754#discussion_r1811421382
##
build.gradle:
##
@@ -318,6 +318,18 @@ subprojects {
options.compilerArgs << "-Werror"
options.release = minJavaVersion
addParametersForTests(name,
m1a2st commented on PR #17246:
URL: https://github.com/apache/kafka/pull/17246#issuecomment-2430284241
my local mashine can run the test
--
This is an automated message from the Apache Git Ser
Greg Harris created KAFKA-17857:
---
Summary: Move AbstractResetIntegrationTest and subclasses to tools
Key: KAFKA-17857
URL: https://issues.apache.org/jira/browse/KAFKA-17857
Project: Kafka
Issue
apoorvmittal10 commented on code in PR #17322:
URL: https://github.com/apache/kafka/pull/17322#discussion_r1811378934
##
share/src/main/java/org/apache/kafka/server/share/fetch/ShareAcquiredRecords.java:
##
@@ -0,0 +1,72 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF
apoorvmittal10 commented on code in PR #17322:
URL: https://github.com/apache/kafka/pull/17322#discussion_r1811354547
##
core/src/main/java/kafka/server/share/SharePartition.java:
##
@@ -1138,6 +1185,7 @@ private void acquireSubsetBatchRecords(
} finally {
kevin-wu24 opened a new pull request, #17582:
URL: https://github.com/apache/kafka/pull/17582
This PR continues on the work of https://github.com/apache/kafka/pull/16991
From discussion, the changes regarding feature levels in the previous PR is
considered out of scope for this change
[
https://issues.apache.org/jira/browse/KAFKA-17114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-17114.
-
Resolution: Cannot Reproduce
We did push some fixed for related tickets. Closing this fo
[
https://issues.apache.org/jira/browse/KAFKA-9323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reopened KAFKA-9323:
> Refactor Streams' upgrade system tests
> ---
>
>
[
https://issues.apache.org/jira/browse/KAFKA-9323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-9323.
Resolution: Fixed
> Refactor Streams' upgrade system tests
> -
kirktrue opened a new pull request, #17581:
URL: https://github.com/apache/kafka/pull/17581
Removing "zk" in the list of quorum values to test in a handful of core
integration tests. This does not remove all occurrences.
### Committer Checklist (excluded from commit message)
- [ ]
[
https://issues.apache.org/jira/browse/KAFKA-17402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-17402.
-
Resolution: Cannot Reproduce
We did put out some fixes for related tickets. Closing this
apoorvmittal10 commented on PR #16842:
URL: https://github.com/apache/kafka/pull/16842#issuecomment-2430141614
@junrao Sorry, I was in middle of my changes when last reviewed. But thanks
for the feedback. I have completed the changes now, can you please re-review.
Sorry for the trouble.
-
apoorvmittal10 commented on code in PR #16842:
URL: https://github.com/apache/kafka/pull/16842#discussion_r1811306002
##
core/src/main/java/kafka/server/share/SharePartitionManager.java:
##
@@ -603,22 +612,43 @@ private void maybeCompleteInitializationWithException(
apoorvmittal10 commented on code in PR #16842:
URL: https://github.com/apache/kafka/pull/16842#discussion_r1811300432
##
core/src/main/java/kafka/server/share/SharePartitionManager.java:
##
@@ -603,22 +612,43 @@ private void maybeCompleteInitializationWithException(
apoorvmittal10 commented on code in PR #16842:
URL: https://github.com/apache/kafka/pull/16842#discussion_r1811299985
##
core/src/main/java/kafka/server/share/SharePartitionManager.java:
##
@@ -594,7 +602,8 @@ private SharePartition
getOrCreateSharePartition(SharePartitionKey s
apoorvmittal10 commented on code in PR #16842:
URL: https://github.com/apache/kafka/pull/16842#discussion_r1811299548
##
core/src/main/java/kafka/server/share/SharePartition.java:
##
@@ -228,6 +240,11 @@ public static RecordState forId(byte id) {
*/
private int stateE
chia7712 commented on code in PR #17322:
URL: https://github.com/apache/kafka/pull/17322#discussion_r1811288562
##
core/src/main/java/kafka/server/share/SharePartition.java:
##
@@ -1658,6 +1706,26 @@ private long findLastOffsetAcknowledged() {
return lastOffsetAcknowled
apoorvmittal10 commented on code in PR #16842:
URL: https://github.com/apache/kafka/pull/16842#discussion_r1811298975
##
core/src/main/java/kafka/server/share/SharePartition.java:
##
@@ -1497,17 +1535,29 @@ private long findLastOffsetAcknowledged() {
}
// Visible for
chia7712 merged PR #17577:
URL: https://github.com/apache/kafka/pull/17577
--
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
Chia-Ping Tsai created KAFKA-17856:
--
Summary: Move ConfigCommandTest and ConfigCommandIntegrationTest
to tool module
Key: KAFKA-17856
URL: https://issues.apache.org/jira/browse/KAFKA-17856
Project: K
[
https://issues.apache.org/jira/browse/KAFKA-17499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17891978#comment-17891978
]
Matthias J. Sax commented on KAFKA-17499:
-
It was never confirmed as a bug (and
junrao commented on code in PR #17322:
URL: https://github.com/apache/kafka/pull/17322#discussion_r1811257578
##
core/src/main/java/kafka/server/share/SharePartition.java:
##
@@ -1658,6 +1706,26 @@ private long findLastOffsetAcknowledged() {
return lastOffsetAcknowledge
chia7712 merged PR #17201:
URL: https://github.com/apache/kafka/pull/17201
--
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-17526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-17526.
Fix Version/s: 4.0.0
Resolution: Fixed
> make ConfigCommandIntegrationTest.java tes
chia7712 commented on code in PR #17322:
URL: https://github.com/apache/kafka/pull/17322#discussion_r1811253140
##
core/src/main/java/kafka/server/share/SharePartition.java:
##
@@ -1138,6 +1185,7 @@ private void acquireSubsetBatchRecords(
} finally {
lock.w
m1a2st commented on code in PR #16965:
URL: https://github.com/apache/kafka/pull/16965#discussion_r1811237660
##
clients/src/test/java/org/apache/kafka/common/security/ssl/CommonNameLoggingTrustManagerFactoryWrapperTest.java:
##
@@ -122,7 +122,7 @@ void testNeverExpiringX509Cert
chia7712 commented on code in PR #17322:
URL: https://github.com/apache/kafka/pull/17322#discussion_r1811236968
##
core/src/main/java/kafka/server/share/SharePartition.java:
##
@@ -1658,6 +1706,26 @@ private long findLastOffsetAcknowledged() {
return lastOffsetAcknowled
[
https://issues.apache.org/jira/browse/KAFKA-15494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17891973#comment-17891973
]
Said BOUDJELDA commented on KAFKA-15494:
[~gharris1727] in progress
> Remove d
m1a2st commented on code in PR #16965:
URL: https://github.com/apache/kafka/pull/16965#discussion_r1811235709
##
build.gradle:
##
@@ -113,11 +113,22 @@ ext {
commitId = determineCommitId()
- addParametersForTests = { name, options ->
+ configureJavaCompiler = { name, op
[
https://issues.apache.org/jira/browse/KAFKA-17686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17686:
--
Reviewer: Chia-Ping Tsai
> AsyncKafkaConsumer.offsetsForTimes() fails with NullPointerException
>
[
https://issues.apache.org/jira/browse/KAFKA-17813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-17813.
-
Fix Version/s: 4.0.0
Resolution: Fixed
merged the PR to trunk
> Create server connection id clas
junrao merged PR #17519:
URL: https://github.com/apache/kafka/pull/17519
--
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
m1a2st commented on PR #17246:
URL: https://github.com/apache/kafka/pull/17246#issuecomment-2430007461
Thanks for your suggestion, I will be change it to plain Java
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
U
[
https://issues.apache.org/jira/browse/KAFKA-17855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Schofield reassigned KAFKA-17855:
Assignee: Andrew Schofield
> Improve documentation for transactions in the light
AndrewJSchofield commented on PR #17454:
URL: https://github.com/apache/kafka/pull/17454#issuecomment-2429996766
https://issues.apache.org/jira/browse/KAFKA-17855 is the continuation of
this work which depends upon KIP-1050.
--
This is an automated message from the Apache Git Service.
To
Andrew Schofield created KAFKA-17855:
Summary: Improve documentation for transactions in the light of
KIP-1050
Key: KAFKA-17855
URL: https://issues.apache.org/jira/browse/KAFKA-17855
Project: Kafk
chia7712 merged PR #17353:
URL: https://github.com/apache/kafka/pull/17353
--
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 #17576:
URL: https://github.com/apache/kafka/pull/17576#issuecomment-2429991154
We are planning to drop JDK 11 for server modules
(https://issues.apache.org/jira/browse/KAFKA-16096), and the base image for E2E
has already been updated to use JDK 17 (#17520). Therefo
kirktrue closed pull request #17529: [WIP] Update GroupRebalanceConfig to not
require session.timeout.ms
URL: https://github.com/apache/kafka/pull/17529
--
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
chia7712 commented on code in PR #16965:
URL: https://github.com/apache/kafka/pull/16965#discussion_r1811204610
##
build.gradle:
##
@@ -113,11 +113,22 @@ ext {
commitId = determineCommitId()
- addParametersForTests = { name, options ->
+ configureJavaCompiler = { name,
kirktrue commented on PR #17353:
URL: https://github.com/apache/kafka/pull/17353#issuecomment-2429980842
@chia7712 / @lianetm—tests are passing and comments have been addressed. Can
you provide another pass of reviews? Thanks!
--
This is an automated message from the Apache Git Service.
T
kirktrue commented on PR #17035:
URL: https://github.com/apache/kafka/pull/17035#issuecomment-2429977853
@lianetm—tests are passing and all comments have been addressed. Can you
make another review pass? Thanks!
--
This is an automated message from the Apache Git Service.
To respond to th
[
https://issues.apache.org/jira/browse/KAFKA-17854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-17854:
--
Assignee: Jhen Yung Hsu (was: Chia-Ping Tsai)
> add tests for `ReadOnlyWindowStoreSt
chia7712 commented on PR #17574:
URL: https://github.com/apache/kafka/pull/17574#issuecomment-2429951900
close as duplicate to #17540
--
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
chia7712 merged PR #17572:
URL: https://github.com/apache/kafka/pull/17572
--
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 merged PR #17540:
URL: https://github.com/apache/kafka/pull/17540
--
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 #17574:
URL: https://github.com/apache/kafka/pull/17574#issuecomment-2429952854
@vlade1k thanks for your contribution. Please feel free to ping me on your
next PR
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
chia7712 closed pull request #17574: MINOR: Fix strange if statements
URL: https://github.com/apache/kafka/pull/17574
--
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 unsubsc
1 - 100 of 199 matches
Mail list logo
