Yunyung commented on code in PR #20152:
URL: https://github.com/apache/kafka/pull/20152#discussion_r2202317949
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java:
##
@@ -1407,7 +1408,8 @@ public GroupCoordinatorMetrics(Metrics metrics,
Yunyung commented on code in PR #20152:
URL: https://github.com/apache/kafka/pull/20152#discussion_r2202317949
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java:
##
@@ -1407,7 +1408,8 @@ public GroupCoordinatorMetrics(Metrics metrics,
Yunyung commented on code in PR #20152:
URL: https://github.com/apache/kafka/pull/20152#discussion_r2202317949
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java:
##
@@ -1407,7 +1408,8 @@ public GroupCoordinatorMetrics(Metrics metrics,
Yunyung commented on code in PR #20152:
URL: https://github.com/apache/kafka/pull/20152#discussion_r2202317949
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java:
##
@@ -1407,7 +1408,8 @@ public GroupCoordinatorMetrics(Metrics metrics,
Yunyung commented on code in PR #20152:
URL: https://github.com/apache/kafka/pull/20152#discussion_r2202317949
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java:
##
@@ -1407,7 +1408,8 @@ public GroupCoordinatorMetrics(Metrics metrics,
github-actions[bot] commented on PR #14380:
URL: https://github.com/apache/kafka/pull/14380#issuecomment-3064603045
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 #20105:
URL: https://github.com/apache/kafka/pull/20105#issuecomment-3064601795
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
DL1231 commented on code in PR #20152:
URL: https://github.com/apache/kafka/pull/20152#discussion_r2202281405
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java:
##
@@ -1407,7 +1408,8 @@ public GroupCoordinatorMetrics(Metrics metrics, S
Yunyung commented on code in PR #20152:
URL: https://github.com/apache/kafka/pull/20152#discussion_r2202250159
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java:
##
@@ -1407,7 +1408,8 @@ public GroupCoordinatorMetrics(Metrics metrics,
Yunyung commented on code in PR #20152:
URL: https://github.com/apache/kafka/pull/20152#discussion_r2202250159
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java:
##
@@ -1407,7 +1408,8 @@ public GroupCoordinatorMetrics(Metrics metrics,
Yunyung commented on code in PR #20152:
URL: https://github.com/apache/kafka/pull/20152#discussion_r2202250159
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java:
##
@@ -1407,7 +1408,8 @@ public GroupCoordinatorMetrics(Metrics metrics,
Yunyung commented on code in PR #20152:
URL: https://github.com/apache/kafka/pull/20152#discussion_r2202250159
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java:
##
@@ -1407,7 +1408,8 @@ public GroupCoordinatorMetrics(Metrics metrics,
Yunyung commented on code in PR #20152:
URL: https://github.com/apache/kafka/pull/20152#discussion_r2202250159
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java:
##
@@ -1407,7 +1408,8 @@ public GroupCoordinatorMetrics(Metrics metrics,
Yunyung commented on code in PR #20152:
URL: https://github.com/apache/kafka/pull/20152#discussion_r2202250159
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java:
##
@@ -1407,7 +1408,8 @@ public GroupCoordinatorMetrics(Metrics metrics,
Yunyung commented on code in PR #20152:
URL: https://github.com/apache/kafka/pull/20152#discussion_r2202250159
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java:
##
@@ -1407,7 +1408,8 @@ public GroupCoordinatorMetrics(Metrics metrics,
DL1231 commented on code in PR #20152:
URL: https://github.com/apache/kafka/pull/20152#discussion_r2202240436
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java:
##
@@ -1407,7 +1408,8 @@ public GroupCoordinatorMetrics(Metrics metrics, S
m1a2st commented on code in PR #20068:
URL: https://github.com/apache/kafka/pull/20068#discussion_r2202210131
##
core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala:
##
@@ -2850,6 +2851,20 @@ class PlaintextAdminIntegrationTest extends
BaseAdminIntegra
chickenchickenlove opened a new pull request, #20159:
URL: https://github.com/apache/kafka/pull/20159
### Changes
- Add new Exception class `PotentialCauseException`.
- All `org.apache.kafka.common.errors.TimeoutException` in `KafkaProducer`
has `PotentialCauseException` as root caus
Yunyung commented on code in PR #20021:
URL: https://github.com/apache/kafka/pull/20021#discussion_r2202009032
##
metadata/src/test/java/org/apache/kafka/image/loader/MetadataLoaderTest.java:
##
@@ -508,6 +513,61 @@ public void testLoadEmptyBatch() throws Exception {
fa
wernerdv commented on PR #20158:
URL: https://github.com/apache/kafka/pull/20158#issuecomment-3063950378
@chia7712 When you get a chance, could you please 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
wernerdv opened a new pull request, #20158:
URL: https://github.com/apache/kafka/pull/20158
Move FetchSession and related classes to server module and rewrite in
Java.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
Forest0923 commented on code in PR #20131:
URL: https://github.com/apache/kafka/pull/20131#discussion_r2201878623
##
storage/src/main/java/org/apache/kafka/storage/internals/log/AbstractIndex.java:
##
@@ -48,7 +47,12 @@ private enum SearchResultType {
private static final
junrao commented on code in PR #20131:
URL: https://github.com/apache/kafka/pull/20131#discussion_r2201522171
##
storage/src/main/java/org/apache/kafka/storage/internals/log/AbstractIndex.java:
##
@@ -48,7 +47,12 @@ private enum SearchResultType {
private static final Log
lucliu1108 opened a new pull request, #20157:
URL: https://github.com/apache/kafka/pull/20157
For the Kafka Stream group commands, if delete topic requests fail due to
version mismatch, user will have to remove the topics manually by first
retrieving the relevant internal topics.
To
chia7712 commented on code in PR #19905:
URL: https://github.com/apache/kafka/pull/19905#discussion_r2201453387
##
tools/src/main/java/org/apache/kafka/tools/LogCompactionTester.java:
##
@@ -0,0 +1,505 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
Yunyung commented on code in PR #20155:
URL: https://github.com/apache/kafka/pull/20155#discussion_r2201444279
##
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/HandlingSourceTopicDeletionIntegrationTest.java:
##
@@ -42,10 +42,13 @@
import java.uti
sjhajharia opened a new pull request, #20156:
URL: https://github.com/apache/kafka/pull/20156
Now that Kafka support Java 17, this PR makes some changes in connect
module. The changes in this PR are limited to only some files. A future
PR(s) shall follow.
The changes mostly inclu
Kevin Wu created KAFKA-19497:
Summary: Topic replay code does not handle creation and deletion
properly if it occurs in the same batch
Key: KAFKA-19497
URL: https://issues.apache.org/jira/browse/KAFKA-19497
[
https://issues.apache.org/jira/browse/KAFKA-18681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jonah Hooper resolved KAFKA-18681.
--
Resolution: Implemented
> GetReplicaLogInfo request
> -
>
>
kevin-wu24 commented on code in PR #19982:
URL: https://github.com/apache/kafka/pull/19982#discussion_r2201295733
##
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientReconfigTest.java:
##
@@ -374,26 +428,105 @@ public void testAddVoter() throws Exception {
ap
kevin-wu24 commented on code in PR #19982:
URL: https://github.com/apache/kafka/pull/19982#discussion_r2201295733
##
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientReconfigTest.java:
##
@@ -374,26 +428,105 @@ public void testAddVoter() throws Exception {
ap
kevin-wu24 commented on code in PR #19982:
URL: https://github.com/apache/kafka/pull/19982#discussion_r2201295733
##
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientReconfigTest.java:
##
@@ -374,26 +428,105 @@ public void testAddVoter() throws Exception {
ap
kevin-wu24 commented on code in PR #19982:
URL: https://github.com/apache/kafka/pull/19982#discussion_r2201295733
##
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientReconfigTest.java:
##
@@ -374,26 +428,105 @@ public void testAddVoter() throws Exception {
ap
junrao commented on code in PR #20121:
URL: https://github.com/apache/kafka/pull/20121#discussion_r2201285845
##
core/src/test/scala/unit/kafka/server/LogRecoveryTest.scala:
##
@@ -64,6 +64,16 @@ class LogRecoveryTest extends QuorumTestHarness {
def hwFile2 = new OffsetCheckp
kevin-wu24 commented on code in PR #19982:
URL: https://github.com/apache/kafka/pull/19982#discussion_r2201283044
##
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientReconfigTest.java:
##
@@ -374,26 +428,105 @@ public void testAddVoter() throws Exception {
ap
karuturi commented on code in PR #20121:
URL: https://github.com/apache/kafka/pull/20121#discussion_r2201246590
##
core/src/test/scala/unit/kafka/server/LogRecoveryTest.scala:
##
@@ -64,6 +64,12 @@ class LogRecoveryTest extends QuorumTestHarness {
def hwFile2 = new OffsetChec
karuturi commented on code in PR #20121:
URL: https://github.com/apache/kafka/pull/20121#discussion_r2201263896
##
core/src/test/scala/unit/kafka/server/LogRecoveryTest.scala:
##
@@ -64,6 +64,12 @@ class LogRecoveryTest extends QuorumTestHarness {
def hwFile2 = new OffsetChec
karuturi commented on code in PR #20121:
URL: https://github.com/apache/kafka/pull/20121#discussion_r2201246590
##
core/src/test/scala/unit/kafka/server/LogRecoveryTest.scala:
##
@@ -64,6 +64,12 @@ class LogRecoveryTest extends QuorumTestHarness {
def hwFile2 = new OffsetChec
jsancio commented on code in PR #19982:
URL: https://github.com/apache/kafka/pull/19982#discussion_r2201032910
##
raft/src/main/java/org/apache/kafka/raft/internals/AddVoterHandler.java:
##
@@ -184,7 +185,8 @@ public CompletableFuture
handleAddVoterRequest(
AddVoterHan
Yunyung commented on code in PR #20152:
URL: https://github.com/apache/kafka/pull/20152#discussion_r2201150928
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java:
##
@@ -1407,7 +1408,8 @@ public GroupCoordinatorMetrics(Metrics metrics,
junrao commented on code in PR #20121:
URL: https://github.com/apache/kafka/pull/20121#discussion_r2201203837
##
core/src/test/scala/unit/kafka/server/LogRecoveryTest.scala:
##
@@ -64,6 +64,12 @@ class LogRecoveryTest extends QuorumTestHarness {
def hwFile2 = new OffsetCheckp
apoorvmittal10 commented on code in PR #20124:
URL: https://github.com/apache/kafka/pull/20124#discussion_r2201148519
##
core/src/test/java/kafka/server/share/SharePartitionTest.java:
##
@@ -7467,6 +7468,164 @@ public void
testNextFetchOffsetWhenOffsetsHaveOngoingTransition() {
fonsdant commented on PR #18610:
URL: https://github.com/apache/kafka/pull/18610#issuecomment-3062905094
@agavra, sorry for the delay, I am resuming the work. How could I check the
coverage report for streams only? According on readme, I can run `gradle
streams:reportCoverage`, but when I d
RaidenE1 opened a new pull request, #20155:
URL: https://github.com/apache/kafka/pull/20155
Fix an integration test error:
In the old version, the `HandlingSouceTopicDeleteIntegrationTest` expects
state change to `ERROR` in both old and new protocols, but in the new protocol,
we sho
bbejeck closed pull request #19407: MINOR: Only send endpoints to partitions on
changes
URL: https://github.com/apache/kafka/pull/19407
--
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 c
apoorvmittal10 merged PR #20153:
URL: https://github.com/apache/kafka/pull/20153
--
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 commented on PR #20153:
URL: https://github.com/apache/kafka/pull/20153#issuecomment-3062523514
Unrelated test failure: which is fixed in
https://github.com/apache/kafka/pull/20154
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
apoorvmittal10 commented on code in PR #20152:
URL: https://github.com/apache/kafka/pull/20152#discussion_r2200852049
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java:
##
@@ -1407,7 +1408,8 @@ public GroupCoordinatorMetrics(Metrics me
kevin-wu24 commented on code in PR #19982:
URL: https://github.com/apache/kafka/pull/19982#discussion_r2198365307
##
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientReconfigTest.java:
##
@@ -374,26 +428,104 @@ public void testAddVoter() throws Exception {
ap
bbejeck commented on PR #20127:
URL: https://github.com/apache/kafka/pull/20127#issuecomment-3062444346
@lucasbru failure is relevant - imports format
--
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
kevin-wu24 commented on code in PR #20136:
URL: https://github.com/apache/kafka/pull/20136#discussion_r2200807511
##
core/src/test/scala/unit/kafka/tools/StorageToolTest.scala:
##
@@ -376,6 +376,8 @@ Found problem:
val availableDirs = Seq(TestUtils.tempDir())
val prope
AndrewJSchofield commented on code in PR #20152:
URL: https://github.com/apache/kafka/pull/20152#discussion_r2200806387
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java:
##
@@ -1407,7 +1408,8 @@ public GroupCoordinatorMetrics(Metrics
kevin-wu24 commented on code in PR #20136:
URL: https://github.com/apache/kafka/pull/20136#discussion_r2200806228
##
core/src/main/scala/kafka/tools/StorageTool.scala:
##
@@ -135,6 +135,15 @@ object StorageTool extends Logging {
featureNamesAndLevels(_).foreachEntry {
lucasbru merged PR #20154:
URL: https://github.com/apache/kafka/pull/20154
--
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
lucasbru commented on PR #20154:
URL: https://github.com/apache/kafka/pull/20154#issuecomment-3062406676
Ah, this was actually introduced by @RaidenE1 's change. Thanks for fixing
@aliehsaeedii
--
This is an automated message from the Apache Git Service.
To respond to the message, please
k-raina commented on code in PR #20144:
URL: https://github.com/apache/kafka/pull/20144#discussion_r2200665834
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java:
##
@@ -717,7 +718,7 @@ private Optional>
createPushRequest(ClientTel
aliehsaeedii opened a new pull request, #20154:
URL: https://github.com/apache/kafka/pull/20154
This fixes the flaky
`DescribeStreamsGroupTest.testDescribeMultipleStreamsGroupWithMembersAndVerboseOptions()`,
which sometimes fails due to `ERROR stream-thread Missing source topics:
Source to
AndrewJSchofield commented on code in PR #19820:
URL: https://github.com/apache/kafka/pull/19820#discussion_r2200620277
##
tools/src/main/java/org/apache/kafka/tools/consumer/group/ShareGroupCommand.java:
##
@@ -366,6 +378,67 @@ Entry>
sendDeleteShareGroupOffsetsRequest(Stri
mimaison merged PR #20151:
URL: https://github.com/apache/kafka/pull/20151
--
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
Apoorv Mittal created KAFKA-19496:
-
Summary: Failing test:
DescribeStreamsGroupTest.testDescribeMultipleStreamsGroupWithMembersAndVerboseOptions()
Key: KAFKA-19496
URL: https://issues.apache.org/jira/browse/KAFKA-
[
https://issues.apache.org/jira/browse/KAFKA-19496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal updated KAFKA-19496:
--
Component/s: streams
> Failing test:
> DescribeStreamsGroupTest.testDescribeMultipleStreamsGr
apoorvmittal10 commented on code in PR #20144:
URL: https://github.com/apache/kafka/pull/20144#discussion_r2200612707
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java:
##
@@ -717,7 +718,7 @@ private Optional>
createPushRequest(Cl
apoorvmittal10 commented on code in PR #20144:
URL: https://github.com/apache/kafka/pull/20144#discussion_r2200612707
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java:
##
@@ -717,7 +718,7 @@ private Optional>
createPushRequest(Cl
lucasbru commented on code in PR #17942:
URL: https://github.com/apache/kafka/pull/17942#discussion_r2200535462
##
streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java:
##
@@ -619,6 +619,10 @@ public class StreamsConfig extends AbstractConfig {
"support \"c
AndrewJSchofield commented on PR #19820:
URL: https://github.com/apache/kafka/pull/19820#issuecomment-3062032067
Thanks for the updates. I'm starting to review and test it. Here's a small
problem I've found so far. `SG1` is an existing share group with 1 member. `T2`
doesn't exist, so the m
karuturi commented on code in PR #20121:
URL: https://github.com/apache/kafka/pull/20121#discussion_r2200524063
##
core/src/test/scala/unit/kafka/server/LogRecoveryTest.scala:
##
@@ -215,7 +215,7 @@ class LogRecoveryTest extends QuorumTestHarness {
server2.startup()
up
k-raina commented on code in PR #20144:
URL: https://github.com/apache/kafka/pull/20144#discussion_r2200520116
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java:
##
@@ -717,7 +718,7 @@ private Optional>
createPushRequest(ClientTel
adixitconfluent commented on code in PR #20124:
URL: https://github.com/apache/kafka/pull/20124#discussion_r2200500905
##
core/src/main/java/kafka/server/share/SharePartition.java:
##
@@ -2834,26 +2850,35 @@ final class AcquisitionLockTimerTask extends TimerTask {
priva
DL1231 commented on code in PR #20148:
URL: https://github.com/apache/kafka/pull/20148#discussion_r2200440939
##
test-common/test-common-runtime/src/main/java/org/apache/kafka/common/test/ClusterInstance.java:
##
@@ -178,12 +179,16 @@ default ShareConsumer shareConsumer() {
AndrewJSchofield commented on code in PR #20124:
URL: https://github.com/apache/kafka/pull/20124#discussion_r2200429775
##
core/src/main/java/kafka/server/share/SharePartition.java:
##
@@ -2834,26 +2850,35 @@ final class AcquisitionLockTimerTask extends TimerTask {
priv
AndrewJSchofield commented on code in PR #20148:
URL: https://github.com/apache/kafka/pull/20148#discussion_r2200382575
##
test-common/test-common-runtime/src/main/java/org/apache/kafka/common/test/ClusterInstance.java:
##
@@ -178,12 +179,16 @@ default ShareConsumer shareConsum
AndrewJSchofield commented on code in PR #20061:
URL: https://github.com/apache/kafka/pull/20061#discussion_r2200340434
##
coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorMetadataImage.java:
##
@@ -0,0 +1,145 @@
+/*
+ * Licensed to the Apa
squah-confluent commented on code in PR #20055:
URL: https://github.com/apache/kafka/pull/20055#discussion_r2200292220
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/consumer/CurrentAssignmentBuilder.java:
##
@@ -151,14 +210,18 @@ public ConsumerGro
squah-confluent commented on code in PR #20055:
URL: https://github.com/apache/kafka/pull/20055#discussion_r2200278950
##
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/assignor/CurrentAssignmentBuilderBenchmark.java:
##
@@ -0,0 +1,171 @@
+/*
+ * Licensed to the Apache Softwa
apoorvmittal10 opened a new pull request, #20153:
URL: https://github.com/apache/kafka/pull/20153
Moving rollback out of lock, if persister returns a completed future for
write state then same data-plane-request-handler thread should not call
purgatory safeTryAndComplete while holding Share
squah-confluent commented on code in PR #20055:
URL: https://github.com/apache/kafka/pull/20055#discussion_r2200219203
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -3463,15 +3488,16 @@ private ConsumerGroupMember maybeRec
TaiJuWu commented on code in PR #20068:
URL: https://github.com/apache/kafka/pull/20068#discussion_r2200218526
##
core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala:
##
@@ -2850,6 +2851,21 @@ class PlaintextAdminIntegrationTest extends
BaseAdminIntegr
frankvicky merged PR #20150:
URL: https://github.com/apache/kafka/pull/20150
--
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.apac
showuon commented on code in PR #20150:
URL: https://github.com/apache/kafka/pull/20150#discussion_r2200188061
##
docker/native/native-image-configs/reflect-config.json:
##
@@ -1023,6 +1023,12 @@
"name":"org.apache.kafka.common.security.kerberos.KerberosLogin",
"methods":[
jim0987795064 commented on code in PR #20068:
URL: https://github.com/apache/kafka/pull/20068#discussion_r2200177131
##
core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala:
##
@@ -2850,6 +2851,21 @@ class PlaintextAdminIntegrationTest extends
BaseAdmin
frankvicky commented on code in PR #20150:
URL: https://github.com/apache/kafka/pull/20150#discussion_r2200158960
##
docker/native/native-image-configs/reflect-config.json:
##
@@ -1023,6 +1023,12 @@
"name":"org.apache.kafka.common.security.kerberos.KerberosLogin",
"methods
[
https://issues.apache.org/jira/browse/KAFKA-19495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen reassigned KAFKA-19495:
-
Assignee: Luke Chen
> DefaultJwtRetriever could not be found with Docker native image
> ---
[
https://issues.apache.org/jira/browse/KAFKA-19495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18004644#comment-18004644
]
Luke Chen commented on KAFKA-19495:
---
PR: [https://github.com/apache/kafka/pull/20150]
sjhajharia commented on PR #19871:
URL: https://github.com/apache/kafka/pull/19871#issuecomment-3061304994
Hey @chia7712 @frankvicky
Given that you both reviewed the first PR in this series, could you pls take
a look at this one too if possible.
Thanks in advance!
--
This is an aut
DL1231 commented on code in PR #20152:
URL: https://github.com/apache/kafka/pull/20152#discussion_r2200095433
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java:
##
@@ -1407,7 +1408,8 @@ public GroupCoordinatorMetrics(Metrics metrics, S
lucasbru commented on code in PR #20055:
URL: https://github.com/apache/kafka/pull/20055#discussion_r2200084635
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/consumer/CurrentAssignmentBuilder.java:
##
@@ -151,14 +210,18 @@ public ConsumerGroupMembe
DL1231 opened a new pull request, #20152:
URL: https://github.com/apache/kafka/pull/20152
Currently, it appears that the small sampling window size is causing
distortion in metrics with larger time windows.
The default configuration samples two windows, each 30 seconds long. If
rebalance
showuon opened a new pull request, #20151:
URL: https://github.com/apache/kafka/pull/20151
The same change for v4.1.0 as this
[PR](https://github.com/apache/kafka/pull/20150).
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
showuon opened a new pull request, #20150:
URL: https://github.com/apache/kafka/pull/20150
We failed the native image build and test workflow
[here](https://github.com/apache/kafka/actions/runs/16211393417/job/45772104969).
The failed messages are:
```
Exception in thread "main" java.
zzbennett commented on code in PR #20061:
URL: https://github.com/apache/kafka/pull/20061#discussion_r2200053645
##
coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorRuntime.java:
##
@@ -2474,37 +2472,37 @@ public void scheduleUnloadOperatio
kapoorpalak21999 commented on code in PR #19943:
URL: https://github.com/apache/kafka/pull/19943#discussion_r2200028139
##
NOTICE-binary:
##
@@ -248,14 +248,14 @@ javaee-api (7.0)
* License: Apache-2.0 AND W3C
-JUnit (4.11)
+JUnit (5.10.2)
-* License: Common Public Licens
[
https://issues.apache.org/jira/browse/KAFKA-19494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma resolved KAFKA-19494.
-
Resolution: Fixed
> Undeprecate JoinGroup V0 & V1 in 3.x
>
ijuma merged PR #20142:
URL: https://github.com/apache/kafka/pull/20142
--
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
TaiJuWu commented on code in PR #20061:
URL: https://github.com/apache/kafka/pull/20061#discussion_r2199874395
##
coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/KRaftCoordinatorMetadataDelta.java:
##
@@ -0,0 +1,82 @@
+/*
+ * Licensed to the Apache S
[
https://issues.apache.org/jira/browse/KAFKA-12512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18004627#comment-18004627
]
Ksolves India Limited commented on KAFKA-12512:
---
Hi [~mumrah] as updated b
[
https://issues.apache.org/jira/browse/KAFKA-12243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18004623#comment-18004623
]
Ksolves India Limited commented on KAFKA-12243:
---
Hi [~jsancio]
Can you ple
96 matches
Mail list logo
