[
https://issues.apache.org/jira/browse/KAFKA-19147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rajini Sivaram resolved KAFKA-19147.
Fix Version/s: 4.1.0
Reviewer: David Jacot
Resolution: Fixed
> ConsumerGro
TaiJuWu commented on code in PR #19286:
URL: https://github.com/apache/kafka/pull/19286#discussion_r2046367913
##
server/src/test/java/org/apache/kafka/server/MonitorablePluginsIntegrationTest.java:
##
@@ -0,0 +1,113 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
Itry1992 opened a new pull request, #19486:
URL: https://github.com/apache/kafka/pull/19486
(no comment)
--
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-m
TaiJuWu commented on code in PR #19460:
URL: https://github.com/apache/kafka/pull/19460#discussion_r2046231461
##
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/admin/ListOffsetsIntegrationTest.java:
##
@@ -0,0 +1,292 @@
+/*
+ * Licensed to the Apache S
TaiJuWu commented on code in PR #19460:
URL: https://github.com/apache/kafka/pull/19460#discussion_r2046233193
##
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/admin/ListOffsetsIntegrationTest.java:
##
@@ -0,0 +1,292 @@
+/*
+ * Licensed to the Apache S
TaiJuWu commented on PR #19460:
URL: https://github.com/apache/kafka/pull/19460#issuecomment-2808612902
> @TaiJuWu please fix the conflicts
Thanks for reminding me. Resolve it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
chia7712 commented on PR #19487:
URL: https://github.com/apache/kafka/pull/19487#issuecomment-2809055110
@gongxuanzhang please revise the title :)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to
squah-confluent commented on code in PR #17444:
URL: https://github.com/apache/kafka/pull/17444#discussion_r2046569906
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/ModernGroup.java:
##
@@ -348,54 +376,58 @@ public Map targetAssignment() {
}
[
https://issues.apache.org/jira/browse/KAFKA-19158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Schofield reassigned KAFKA-19158:
Assignee: Andrew Schofield (was: Chirag Wadhwa)
Summary: Add a new error cod
[
https://issues.apache.org/jira/browse/KAFKA-19162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Brutschy reassigned KAFKA-19162:
--
Assignee: Lucas Brutschy
> Topology description sent to broker contains non-determins
lucasbru commented on PR #19491:
URL: https://github.com/apache/kafka/pull/19491#issuecomment-2809449043
PTAL @aliehsaeedii
--
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.
lucasbru opened a new pull request, #19491:
URL: https://github.com/apache/kafka/pull/19491
Topology description sent to broker in KIP-1071 contains
non-deterministically ordered topic configs.
Since the topology is compared to the groups topology upon joining, it
should be completel
apalan60 commented on code in PR #19394:
URL: https://github.com/apache/kafka/pull/19394#discussion_r2047947955
##
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/StreamsUncaughtExceptionHandlerIntegrationTest.java:
##
@@ -336,16 +339,20 @@ private v
apalan60 commented on code in PR #19394:
URL: https://github.com/apache/kafka/pull/19394#discussion_r2047945194
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java:
##
@@ -869,8 +870,10 @@ public void setStreamsUncaughtExceptionHandler(final
apalan60 commented on PR #19394:
URL: https://github.com/apache/kafka/pull/19394#issuecomment-2811252138
@mjsax Thanks for your review, I've addressed all feedback. PTAL, thanks！
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
junrao commented on code in PR #15968:
URL: https://github.com/apache/kafka/pull/15968#discussion_r2047838466
##
core/src/test/scala/integration/kafka/api/ProducerSendWhileDeletionTest.scala:
##
@@ -85,4 +85,80 @@ class ProducerSendWhileDeletionTest extends
IntegrationTestHarne
[
https://issues.apache.org/jira/browse/KAFKA-19166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur updated KAFKA-19166:
-
Affects Version/s: 3.9.0
4.0.0
> Release tags are orphaned
>
omkreddy opened a new pull request, #19502:
URL: https://github.com/apache/kafka/pull/19502
when you using log41 config, we are printing addtional line like below. This
change is to fix that
For example, cmd ` KAFKA_CLUSTER_ID="$(bin/kafka-storage.sh random-uuid)"s`
gives
[
https://issues.apache.org/jira/browse/KAFKA-16869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lorcan reassigned KAFKA-16869:
--
Assignee: (was: Lorcan)
> Rewrite HighAvailabilityTaskAssignor to implement the new TaskAssignor
frankvicky commented on PR #19501:
URL: https://github.com/apache/kafka/pull/19501#issuecomment-2811891358
Build output:
--
This is an automated message from the Apache Git Service.
To respond
mjsax commented on code in PR #18816:
URL: https://github.com/apache/kafka/pull/18816#discussion_r2040351003
##
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingKeyValueBytesStoreTest.java:
##
@@ -89,8 +95,81 @@ public class ChangeLoggingKeyValueBytesS
AndrewJSchofield opened a new pull request, #19492:
URL: https://github.com/apache/kafka/pull/19492
Add the new `SHARE_SESSION_LIMIT_REACHED` error code which is used when an
attempt is made to open a new share session when the share session limit of the
broker has already been reached. Sup
Yunyung commented on code in PR #19397:
URL: https://github.com/apache/kafka/pull/19397#discussion_r2046923569
##
clients/src/main/java/org/apache/kafka/common/config/provider/ConfigProvider.java:
##
@@ -29,6 +29,10 @@
* Kafka Connect discovers implementations of this interfac
Yunyung commented on code in PR #19397:
URL: https://github.com/apache/kafka/pull/19397#discussion_r2034036959
##
clients/src/main/java/org/apache/kafka/common/config/AbstractConfig.java:
##
@@ -620,21 +621,22 @@ private Map
instantiateConfigProviders(
}
}
Yunyung commented on code in PR #19397:
URL: https://github.com/apache/kafka/pull/19397#discussion_r2046927417
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMakerConfig.java:
##
@@ -269,18 +270,19 @@ List configProviders() {
Map transform(Map props)
Yunyung commented on code in PR #19397:
URL: https://github.com/apache/kafka/pull/19397#discussion_r2046928161
##
clients/src/main/java/org/apache/kafka/common/config/AbstractConfig.java:
##
@@ -620,21 +621,22 @@ private Map
instantiateConfigProviders(
}
}
FrankYang0529 opened a new pull request, #19493:
URL: https://github.com/apache/kafka/pull/19493
* Change `ListClientMetricsResourcesRequest.json` to
`ListConfigResourcesRequest.json`.
* Change `ListClientMetricsResourcesResponse.json` to
`ListConfigResourcesResponse.json`.
* Change `
[
https://issues.apache.org/jira/browse/KAFKA-19157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Schofield updated KAFKA-19157:
-
Description: As described in the updated KIP-932.
Summary: Add group.share.max.sh
smjn commented on code in PR #19478:
URL: https://github.com/apache/kafka/pull/19478#discussion_r2046247231
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java:
##
@@ -1257,38 +1257,103 @@ private CompletableFuture>
persisterDelete
smjn commented on code in PR #19478:
URL: https://github.com/apache/kafka/pull/19478#discussion_r2046245448
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java:
##
@@ -1257,38 +1257,103 @@ private CompletableFuture>
persisterDelete
smjn commented on code in PR #19478:
URL: https://github.com/apache/kafka/pull/19478#discussion_r2046248551
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java:
##
@@ -1257,38 +1257,103 @@ private CompletableFuture>
persisterDelete
smjn commented on code in PR #19478:
URL: https://github.com/apache/kafka/pull/19478#discussion_r2046248961
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java:
##
@@ -1257,38 +1257,103 @@ private CompletableFuture>
persisterDelete
smjn commented on code in PR #19478:
URL: https://github.com/apache/kafka/pull/19478#discussion_r2046254058
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -8200,50 +8200,119 @@ public Optional
shareGroupBuildPartitionDelet
smjn commented on code in PR #19478:
URL: https://github.com/apache/kafka/pull/19478#discussion_r2046256836
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -8200,50 +8200,119 @@ public Optional
shareGroupBuildPartitionDelet
smjn commented on code in PR #19478:
URL: https://github.com/apache/kafka/pull/19478#discussion_r2046256836
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -8200,50 +8200,119 @@ public Optional
shareGroupBuildPartitionDelet
[
https://issues.apache.org/jira/browse/KAFKA-19161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17945052#comment-17945052
]
Stanislav Kozlovski commented on KAFKA-19161:
-
this is AWESOME
> Diskless T
Lucas Brutschy created KAFKA-19162:
--
Summary: Topology description sent to broker contains
non-determinstically ordered topic configs
Key: KAFKA-19162
URL: https://issues.apache.org/jira/browse/KAFKA-19162
smjn commented on code in PR #19443:
URL: https://github.com/apache/kafka/pull/19443#discussion_r2047117734
##
share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorShard.java:
##
@@ -574,6 +575,46 @@ public
CoordinatorResult(List.of(record), respon
lianetm commented on code in PR #19461:
URL: https://github.com/apache/kafka/pull/19461#discussion_r2045463288
##
clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitRequest.java:
##
@@ -45,20 +45,24 @@ public static class Builder extends
AbstractRequest.Builder
dajac commented on code in PR #19461:
URL: https://github.com/apache/kafka/pull/19461#discussion_r2047364604
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/OffsetMetadataManagerTest.java:
##
@@ -1308,6 +1308,75 @@ public void testConsumerGroupOffsetCommit(
AndrewJSchofield merged PR #19492:
URL: https://github.com/apache/kafka/pull/19492
--
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...@kafk
dajac commented on code in PR #17444:
URL: https://github.com/apache/kafka/pull/17444#discussion_r2047369968
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/ModernGroup.java:
##
@@ -348,54 +376,58 @@ public Map targetAssignment() {
}
/**
yunchipang commented on code in PR #19479:
URL: https://github.com/apache/kafka/pull/19479#discussion_r2047369883
##
clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java:
##
@@ -58,8 +58,8 @@ public class TopicConfig {
public static final String FLUSH_MS_CO
dajac commented on PR #17444:
URL: https://github.com/apache/kafka/pull/17444#issuecomment-2810200638
@FrankYang0529 When you update the PR, I wonder whether we could split it
into smaller chunks. That would ease the reviews. Would it be possible?
--
This is an automated message from the
[
https://issues.apache.org/jira/browse/KAFKA-19158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Schofield resolved KAFKA-19158.
--
Fix Version/s: 4.1.0
Resolution: Fixed
> Add a new error code for “share sessio
Sean Quah created KAFKA-19163:
-
Summary: New group coordinator can incorrectly delete groups with
pending transactional offsets
Key: KAFKA-19163
URL: https://issues.apache.org/jira/browse/KAFKA-19163
Proj
dajac merged PR #19485:
URL: https://github.com/apache/kafka/pull/19485
--
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
m1a2st opened a new pull request, #19494:
URL: https://github.com/apache/kafka/pull/19494
(no comment)
--
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-mai
chia7712 commented on code in PR #19494:
URL: https://github.com/apache/kafka/pull/19494#discussion_r2047334846
##
storage/src/test/java/org/apache/kafka/tiered/storage/utils/TieredStorageTestUtils.java:
##
@@ -53,7 +54,6 @@
import static
org.apache.kafka.server.log.remote.sto
m1a2st commented on PR #19472:
URL: https://github.com/apache/kafka/pull/19472#issuecomment-2810141568
I addressed https://github.com/apache/kafka/pull/19494 th fix it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
m1a2st commented on code in PR #19494:
URL: https://github.com/apache/kafka/pull/19494#discussion_r2047337475
##
storage/src/test/java/org/apache/kafka/tiered/storage/utils/TieredStorageTestUtils.java:
##
@@ -53,7 +54,6 @@
import static
org.apache.kafka.server.log.remote.stora
chia7712 commented on code in PR #19191:
URL: https://github.com/apache/kafka/pull/19191#discussion_r2047340719
##
clients/src/main/java/org/apache/kafka/common/Endpoint.java:
##
@@ -16,35 +16,51 @@
*/
package org.apache.kafka.common;
-import org.apache.kafka.common.annotat
chia7712 commented on code in PR #19494:
URL: https://github.com/apache/kafka/pull/19494#discussion_r2047338914
##
storage/src/test/java/org/apache/kafka/tiered/storage/utils/TieredStorageTestUtils.java:
##
@@ -53,7 +54,6 @@
import static
org.apache.kafka.server.log.remote.sto
dajac commented on code in PR #19461:
URL: https://github.com/apache/kafka/pull/19461#discussion_r2047353585
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -271,40 +271,62 @@ class KafkaApis(val requestChannel: RequestChannel,
): CompletableFuture[Unit] = {
v
dajac commented on code in PR #19461:
URL: https://github.com/apache/kafka/pull/19461#discussion_r2047354258
##
clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitResponse.java:
##
@@ -190,12 +203,85 @@ public Builder merge(
}
dajac commented on code in PR #19461:
URL: https://github.com/apache/kafka/pull/19461#discussion_r2047358176
##
clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitRequest.java:
##
@@ -45,20 +45,24 @@ public static class Builder extends
AbstractRequest.Builder
dajac commented on code in PR #19461:
URL: https://github.com/apache/kafka/pull/19461#discussion_r2047360656
##
clients/src/main/resources/common/message/OffsetCommitResponse.json:
##
@@ -34,7 +34,9 @@
// Version 9 is the first version that can be used with the new consumer
dajac commented on code in PR #19461:
URL: https://github.com/apache/kafka/pull/19461#discussion_r2047359577
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -271,40 +271,62 @@ class KafkaApis(val requestChannel: RequestChannel,
): CompletableFuture[Unit] = {
v
dajac commented on code in PR #19461:
URL: https://github.com/apache/kafka/pull/19461#discussion_r2047359577
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -271,40 +271,62 @@ class KafkaApis(val requestChannel: RequestChannel,
): CompletableFuture[Unit] = {
v
chia7712 commented on code in PR #19479:
URL: https://github.com/apache/kafka/pull/19479#discussion_r2047338225
##
clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java:
##
@@ -58,8 +58,8 @@ public class TopicConfig {
public static final String FLUSH_MS_CONF
gongxuanzhang commented on code in PR #19487:
URL: https://github.com/apache/kafka/pull/19487#discussion_r2046991460
##
server/src/main/java/org/apache/kafka/server/config/DynamicConfig.java:
##
@@ -0,0 +1,94 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
FrankYang0529 commented on code in PR #19487:
URL: https://github.com/apache/kafka/pull/19487#discussion_r2046985960
##
server/src/main/java/org/apache/kafka/server/config/DynamicConfig.java:
##
@@ -0,0 +1,94 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
chia7712 commented on code in PR #19477:
URL: https://github.com/apache/kafka/pull/19477#discussion_r2047281878
##
clients/src/main/java/org/apache/kafka/clients/admin/ListGroupsOptions.java:
##
@@ -45,6 +57,11 @@ public ListGroupsOptions inGroupStates(Set
groupStates) {
chia7712 commented on PR #19472:
URL: https://github.com/apache/kafka/pull/19472#issuecomment-2810125777
@frankvicky could you please fix the following warning?
```
> Task :storage:compileTestJava
/home/chia7712/project/kafka/storage/src/test/java/org/apache/kafka/tiered/storage/uti
AndrewJSchofield commented on code in PR #19443:
URL: https://github.com/apache/kafka/pull/19443#discussion_r2047031680
##
share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorShard.java:
##
@@ -574,6 +575,46 @@ public
CoordinatorResult(List.of(rec
kirktrue commented on code in PR #19467:
URL: https://github.com/apache/kafka/pull/19467#discussion_r2047085428
##
clients/src/main/java/org/apache/kafka/common/serialization/Serializer.java:
##
@@ -23,20 +23,25 @@
/**
* An interface for converting objects to bytes.
- *
*
OmniaGM commented on code in PR #15968:
URL: https://github.com/apache/kafka/pull/15968#discussion_r2047099316
##
core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala:
##
@@ -94,9 +94,14 @@ class AuthorizerIntegrationTest extends
AbstractAuthorizerIntegrati
chia7712 merged PR #19490:
URL: https://github.com/apache/kafka/pull/19490
--
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-19163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sean Quah updated KAFKA-19163:
--
Description:
When a group has pending transactional offsets and no committed offsets, the
group coord
ijuma commented on PR #19483:
URL: https://github.com/apache/kafka/pull/19483#issuecomment-2810083718
Thanks for the quick update.
--
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 com
[
https://issues.apache.org/jira/browse/KAFKA-19163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sean Quah updated KAFKA-19163:
--
Description:
When a group has pending transactional offsets and no committed offsets, the
group coord
mjsax commented on PR #19467:
URL: https://github.com/apache/kafka/pull/19467#issuecomment-2810269706
> Are the line breaking changes for the @param JavaDoc a new style
guideline, or one used in Streams? I haven't seen that elsewhere in the project.
I don't think there is any official
Sean Quah created KAFKA-19164:
-
Summary: New group coordinator won't delete groups with previously
pending transactional offsets that were deleted
Key: KAFKA-19164
URL: https://issues.apache.org/jira/browse/KAFKA-1916
AndrewJSchofield commented on code in PR #19477:
URL: https://github.com/apache/kafka/pull/19477#discussion_r2047639023
##
clients/src/main/java/org/apache/kafka/clients/admin/ListGroupsOptions.java:
##
@@ -61,6 +78,13 @@ public Set groupStates() {
return groupStates;
lucasbru commented on PR #19491:
URL: https://github.com/apache/kafka/pull/19491#issuecomment-2810818905
Thanks for the comments. Ready for re-review @mjsax
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
lucasbru commented on code in PR #19491:
URL: https://github.com/apache/kafka/pull/19491#discussion_r2047774189
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsGroupHeartbeatRequestManager.java:
##
@@ -237,6 +237,7 @@ private static
List getRepartiti
lucasbru commented on code in PR #19491:
URL: https://github.com/apache/kafka/pull/19491#discussion_r2047774920
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsGroupHeartbeatRequestManager.java:
##
@@ -490,8 +492,12 @@ private NetworkClientDelegate.Un
Steven Schlansker created KAFKA-19165:
-
Summary: PartitionLeaderStrategy has very high error rate during
topic initialization
Key: KAFKA-19165
URL: https://issues.apache.org/jira/browse/KAFKA-19165
chia7712 commented on code in PR #19465:
URL: https://github.com/apache/kafka/pull/19465#discussion_r2047326389
##
raft/src/main/java/org/apache/kafka/raft/MetadataLogConfig.java:
##
@@ -16,25 +16,161 @@
*/
package org.apache.kafka.raft;
-/**
- * Configuration for the metad
squah-confluent commented on code in PR #19495:
URL: https://github.com/apache/kafka/pull/19495#discussion_r2047494613
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java:
##
@@ -256,7 +263,7 @@ private OffsetAndMetadata remove(
squah-confluent commented on PR #19496:
URL: https://github.com/apache/kafka/pull/19496#issuecomment-2810400896
Marking this as a draft until #19495 is completed, since there is a merge
conflict.
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
squah-confluent opened a new pull request, #19497:
URL: https://github.com/apache/kafka/pull/19497
When fetching stable offsets in the group coordinator, we iterate over
all requested partitions. For each partition, we iterate over the
group's ongoing transactions to check if there is a
jolshan commented on code in PR #19495:
URL: https://github.com/apache/kafka/pull/19495#discussion_r2047758771
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java:
##
@@ -256,7 +263,7 @@ private OffsetAndMetadata remove(
cmccabe commented on PR #19499:
URL: https://github.com/apache/kafka/pull/19499#issuecomment-2810806228
oh, now that I think about it, it won’t claim controllership until all
brokers are changed to be migration enabled. Let me think about this more.
--
This is an automated message from th
cmccabe closed pull request #19499: MINOR: fix docs/ops.html ZK migration docs
URL: https://github.com/apache/kafka/pull/19499
--
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.
T
shaan150 commented on code in PR #19497:
URL: https://github.com/apache/kafka/pull/19497#discussion_r2047739805
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java:
##
@@ -650,24 +658,18 @@ public int deleteAllOffsets(
// Del
[
https://issues.apache.org/jira/browse/KAFKA-18713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17945205#comment-17945205
]
Matthias J. Sax commented on KAFKA-18713:
-
It's very unlikely that 3.8.2 will ac
[
https://issues.apache.org/jira/browse/KAFKA-19024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lan Ding resolved KAFKA-19024.
--
Resolution: Fixed
> Enhance the client behaviour when it tries to exceed the
> `group.share.max.group
chia7712 merged PR #19481:
URL: https://github.com/apache/kafka/pull/19481
--
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-19157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17945210#comment-17945210
]
Lan Ding commented on KAFKA-19157:
--
Hi [~cwadhwa] , If this ticket is still open, may I
chia7712 merged PR #19494:
URL: https://github.com/apache/kafka/pull/19494
--
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
mjsax commented on PR #19404:
URL: https://github.com/apache/kafka/pull/19404#issuecomment-2811620083
@lorcanj Thanks for the PR -- we are currently quite backlogged and it might
take some more time until we get to your PR. Thanks for your understanding.
--
This is an automated message fr
chia7712 commented on code in PR #19498:
URL: https://github.com/apache/kafka/pull/19498#discussion_r2048130537
##
docs/ops.html:
##
@@ -3967,15 +3964,6 @@ The Kafka controllers store all the metadata for the cluster in memory
and on disk. We believe that for a typical Kafka cl
github-actions[bot] closed pull request #17950: KAFKA-7025: Some Android
compatibility for kafka-client
URL: https://github.com/apache/kafka/pull/17950
--
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 t
adixitconfluent commented on code in PR #19437:
URL: https://github.com/apache/kafka/pull/19437#discussion_r2048256117
##
core/src/test/java/kafka/server/share/DelayedShareFetchTest.java:
##
@@ -1155,6 +1170,537 @@ public void testOnCompleteExecutionOnTimeout() {
assert
[
https://issues.apache.org/jira/browse/KAFKA-19166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur updated KAFKA-19166:
-
Fix Version/s: 4.0.1
> Release tags are orphaned
> -
>
>
DL1231 closed pull request #19313: KAFKA-19024 Enhance the client behaviour
when it tries to exceed the `group.share.max.groups`
URL: https://github.com/apache/kafka/pull/19313
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
Chia-Ping Tsai created KAFKA-19167:
--
Summary: Move RemoteLogManagerConfig out of KafkaConfig
Key: KAFKA-19167
URL: https://issues.apache.org/jira/browse/KAFKA-19167
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-19054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-19054:
Affects Version/s: 2.8.0
(was: 3.7.1)
> StreamThread exception
[
https://issues.apache.org/jira/browse/KAFKA-19156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17945211#comment-17945211
]
Lan Ding commented on KAFKA-19156:
--
Hi [~cwadhwa] , If this ticket is still open, may I
1 - 100 of 182 matches
Mail list logo
