[
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
> -
[
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-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
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
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-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
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
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
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)
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_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
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
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
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 {
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
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
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_r1811299548
##
core/src/main/java/kafka/server/share/SharePartition.java:
##
@@ -228,6 +240,11 @@ public static RecordState forId(byte id) {
*/
private int stateE
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
[
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
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_r1811300432
##
core/src/main/java/kafka/server/share/SharePartitionManager.java:
##
@@ -603,22 +612,43 @@ private void maybeCompleteInitializationWithException(
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 {
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 #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 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.
-
[
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
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)
- [ ]
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
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
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,
[
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
>
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
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
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
[
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
[
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#
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
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
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
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 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
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
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
[
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
[
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
apoorvmittal10 commented on code in PR #17578:
URL: https://github.com/apache/kafka/pull/17578#discussion_r1810990883
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java:
##
@@ -707,7 +708,8 @@ private Optional>
createPushRequest(Cl
apoorvmittal10 commented on PR #17519:
URL: https://github.com/apache/kafka/pull/17519#issuecomment-2429697155
@junrao I have addressed the comment, removed brackets, corrected tests and
comments. Please can you review.
--
This is an automated message from the Apache Git Service.
To respo
smjn opened a new pull request, #17580:
URL: https://github.com/apache/kafka/pull/17580
In the `ShareCoordinatorShard.readState` method we are storing the
`leaderEpoch` present in the request directly in the `leaderEpochMap` timeline
hashmap, if it is the highest `leaderEpoch` seen so far f
JerryCai commented on code in PR #17571:
URL: https://github.com/apache/kafka/pull/17571#discussion_r1811010843
##
clients/src/test/java/org/apache/kafka/clients/consumer/AbstractLeaderRackAwareAssignorTest.java:
##
@@ -0,0 +1,158 @@
+/*
+ * Licensed to the Apache Software Found
apoorvmittal10 commented on code in PR #17519:
URL: https://github.com/apache/kafka/pull/17519#discussion_r1811075335
##
clients/src/main/java/org/apache/kafka/common/network/ServerConnectionId.java:
##
@@ -0,0 +1,146 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) u
junrao commented on code in PR #17539:
URL: https://github.com/apache/kafka/pull/17539#discussion_r1811067709
##
core/src/main/java/kafka/server/share/DelayedShareFetch.java:
##
@@ -204,7 +197,62 @@ Map
acquirablePartitions() {
return topicPartitionData;
}
-
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
[
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
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
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
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 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 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
[
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
[
https://issues.apache.org/jira/browse/KAFKA-17844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal resolved KAFKA-17844.
---
Resolution: Fixed
> Add tests and fix to complete share fetch request on exception from mana
Apoorv Mittal created KAFKA-17853:
-
Summary: Console share consumer is not terminated immediately
Key: KAFKA-17853
URL: https://issues.apache.org/jira/browse/KAFKA-17853
Project: Kafka
Issue
AndrewJSchofield commented on code in PR #17454:
URL: https://github.com/apache/kafka/pull/17454#discussion_r1811157856
##
docs/design.html:
##
@@ -254,32 +254,32 @@
-Kafka's semantics are straight-forward. When publishing a message we have
a notion of the message being "c
AndrewJSchofield commented on code in PR #17454:
URL: https://github.com/apache/kafka/pull/17454#discussion_r1811157856
##
docs/design.html:
##
@@ -254,32 +254,32 @@
-Kafka's semantics are straight-forward. When publishing a message we have
a notion of the message being "c
AndrewJSchofield commented on code in PR #17454:
URL: https://github.com/apache/kafka/pull/17454#discussion_r1811160874
##
docs/design.html:
##
@@ -290,24 +290,58 @@ https://kafka.apache.org/documentation/streams";>Kafka Streams
-application), we can leverage the new transac
chia7712 commented on PR #17403:
URL: https://github.com/apache/kafka/pull/17403#issuecomment-2429913928
> I have found that Java 11 will be removed in 4.0.0 version, like we can
see below:
I prefer to update the docs after we do remove the JDK 11 from server-side :)
--
This is an
chia7712 merged PR #17556:
URL: https://github.com/apache/kafka/pull/17556
--
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
junrao commented on code in PR #17519:
URL: https://github.com/apache/kafka/pull/17519#discussion_r1811045144
##
clients/src/main/java/org/apache/kafka/common/network/ServerConnectionId.java:
##
@@ -0,0 +1,146 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
chia7712 merged PR #17568:
URL: https://github.com/apache/kafka/pull/17568
--
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 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
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
Chia-Ping Tsai created KAFKA-17854:
--
Summary: add tests for `ReadOnlyWindowStoreStub#fetch(null, null
...)`
Key: KAFKA-17854
URL: https://issues.apache.org/jira/browse/KAFKA-17854
Project: Kafka
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 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
apoorvmittal10 commented on code in PR #17578:
URL: https://github.com/apache/kafka/pull/17578#discussion_r1810973171
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java:
##
@@ -707,7 +708,8 @@ private Optional>
createPushRequest(Cl
[
https://issues.apache.org/jira/browse/KAFKA-15284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-15284:
-
Assignee: (was: Kirk True)
> Implement ConsumerGroupProtocolVersionResolver to determine co
[
https://issues.apache.org/jira/browse/KAFKA-15284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15284:
--
Summary: Implement GroupProtocolResolver to determine consumer group
protocol (was: Implement Consume
[
https://issues.apache.org/jira/browse/KAFKA-15284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15284:
--
Description:
At client initialization, we need to determine which of the
{{ConsumerDelegate}} impleme
[
https://issues.apache.org/jira/browse/KAFKA-15284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reopened KAFKA-15284:
---
Assignee: Kirk True
> Implement ConsumerGroupProtocolVersionResolver to determine consumer group
[
https://issues.apache.org/jira/browse/KAFKA-15284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15284:
--
Priority: Critical (was: Major)
> Implement GroupProtocolResolver to determine consumer group protoco
frankvicky opened a new pull request, #17579:
URL: https://github.com/apache/kafka/pull/17579
JIRA: [KAFKA-17837](https://issues.apache.org/jira/browse/KAFKA-17837)
Rewrite DeleteTopicTest as Java.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and
apoorvmittal10 commented on code in PR #17570:
URL: https://github.com/apache/kafka/pull/17570#discussion_r1811145523
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java:
##
@@ -337,33 +336,33 @@ public long timeToNextUpdate(long req
AndrewJSchofield commented on code in PR #17454:
URL: https://github.com/apache/kafka/pull/17454#discussion_r1811146922
##
docs/design.html:
##
@@ -254,32 +254,32 @@
-Kafka's semantics are straight-forward. When publishing a message we have
a notion of the message being "c
chia7712 commented on code in PR #17570:
URL: https://github.com/apache/kafka/pull/17570#discussion_r1811150109
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java:
##
@@ -337,33 +336,33 @@ public long timeToNextUpdate(long requestTi
clarkwtc commented on code in PR #17570:
URL: https://github.com/apache/kafka/pull/17570#discussion_r1811037824
##
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-15284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15284:
--
Summary: Implement GroupProtocolResolver to dynamically determine consumer
group protocol (was: Imple
[
https://issues.apache.org/jira/browse/KAFKA-15284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15284:
--
Description:
At client initialization, we need to determine which of the
{{ConsumerDelegate}} impleme
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
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
[
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
[
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
>
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-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
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
1 - 100 of 199 matches
Mail list logo
