showuon commented on PR #12545:
URL: https://github.com/apache/kafka/pull/12545#issuecomment-1521216831
@LinShunKang , could you create a JIRA issue related to this KIP, and make
the PR title started with `KAFKA-: Reduce...` instead of `KIP-xxx:
Reduce...`. Also, the KIP needs to point
showuon commented on PR #12545:
URL: https://github.com/apache/kafka/pull/12545#issuecomment-1521213534
Failed tests are unrelated:
```
Build / JDK 8 and Scala 2.12 /
org.apache.kafka.connect.storage.KafkaStatusBackingStoreFormatTest.putTopicStateRetriableFailure
Build / JDK
Tesseract98 closed pull request #13629: KAFKA-* Update failed nodes cache;
(addresses switch with load balancer)
URL: https://github.com/apache/kafka/pull/13629
--
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
vamossagar12 commented on PR #13594:
URL: https://github.com/apache/kafka/pull/13594#issuecomment-1521193360
@yashmayya , hmm MemoryOffsetBackingStore is used in Connect Standalone
IIUC. I am not totally aware of the historical context here of whether throwing
a ConnectException is valid or
showuon commented on code in PR #13631:
URL: https://github.com/apache/kafka/pull/13631#discussion_r1176030390
##
clients/src/main/java/org/apache/kafka/clients/ApiVersions.java:
##
@@ -64,4 +64,8 @@ public synchronized byte maxUsableProduceMagic() {
return maxUsablePro
showuon commented on code in PR #13631:
URL: https://github.com/apache/kafka/pull/13631#discussion_r1176030100
##
metadata/src/main/java/org/apache/kafka/metadata/migration/KRaftMigrationDriver.java:
##
@@ -134,8 +139,7 @@ private void initializeMigrationState() {
}
showuon commented on code in PR #13631:
URL: https://github.com/apache/kafka/pull/13631#discussion_r1176029069
##
core/src/main/scala/kafka/server/ControllerServer.scala:
##
@@ -270,7 +271,8 @@ class ControllerServer(
"zk migration",
fatal = false,
vamossagar12 commented on code in PR #13594:
URL: https://github.com/apache/kafka/pull/13594#discussion_r1176029043
##
connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaStatusBackingStoreFormatTest.java:
##
@@ -216,7 +216,7 @@ public void putTopicStateRetriable
vamossagar12 opened a new pull request, #13634:
URL: https://github.com/apache/kafka/pull/13634
Fixing flaky test putTopicStateRetriableFailure by adding a timeout to have
the background thread kicked in which invokes KafkaBasedLog#send.
--
This is an automated message from the Apache Git
showuon commented on code in PR #13631:
URL: https://github.com/apache/kafka/pull/13631#discussion_r1176027142
##
metadata/src/test/java/org/apache/kafka/metadata/migration/KRaftMigrationDriverTest.java:
##
@@ -277,64 +312,65 @@ CompletableFuture
enqueueMetadataChangeEventWithF
showuon commented on code in PR #13631:
URL: https://github.com/apache/kafka/pull/13631#discussion_r1176025802
##
metadata/src/test/java/org/apache/kafka/metadata/migration/KRaftMigrationDriverTest.java:
##
@@ -383,8 +466,8 @@ public ZkMigrationLeadershipState
claimControllerLe
hgeraldino commented on PR #13383:
URL: https://github.com/apache/kafka/pull/13383#issuecomment-1521090615
Thanks for your feedback @C0urante.
I finally had time this past week and tweaked the test to address your
comments and fix coverage.
--
This is an automated message from th
hgeraldino commented on code in PR #13383:
URL: https://github.com/apache/kafka/pull/13383#discussion_r1175960799
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSourceTaskTest.java:
##
@@ -474,129 +442,107 @@ public void testFailureInPollAfterStop() thro
hgeraldino commented on code in PR #13383:
URL: https://github.com/apache/kafka/pull/13383#discussion_r1175960401
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSourceTaskTest.java:
##
@@ -1003,31 +868,35 @@ private boolean awaitLatch(CountDownLatch latc
atu-sharm opened a new pull request, #13633:
URL: https://github.com/apache/kafka/pull/13633
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of testi
maulin-vasavada commented on PR #13626:
URL: https://github.com/apache/kafka/pull/13626#issuecomment-1520995629
@machi1990 looks good to me. However you will need a committer to review and
merge this.
--
This is an automated message from the Apache Git Service.
To respond to the message,
mjsax commented on PR #13533:
URL: https://github.com/apache/kafka/pull/13533#issuecomment-1520912631
Merged to `trunk` and cherry-picked to `3.5` branch.
--
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 t
mjsax merged PR #13533:
URL: https://github.com/apache/kafka/pull/13533
--
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
jsancio closed pull request #13030: MINOR; Add log message when Log high
watermark differs
URL: https://github.com/apache/kafka/pull/13030
--
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 specifi
jsancio commented on PR #13030:
URL: https://github.com/apache/kafka/pull/13030#issuecomment-1520845699
Changes included in https://github.com/apache/kafka/pull/13553
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
jeffkbkim commented on code in PR #13538:
URL: https://github.com/apache/kafka/pull/13538#discussion_r1175790304
##
checkstyle/suppressions.xml:
##
@@ -318,6 +318,14 @@
+
+
+
[
https://issues.apache.org/jira/browse/KAFKA-14932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio updated KAFKA-14932:
---
Description:
The implementation in [https://github.com/apache/kafka/
José Armando García Sancio created KAFKA-14932:
--
Summary: Heuristic for increasing the log start offset after
replicas are caught up
Key: KAFKA-14932
URL: https://issues.apache.org/jira/browse/KAFKA-1
mjsax commented on PR #13615:
URL: https://github.com/apache/kafka/pull/13615#issuecomment-1520833481
Merged to `trunk` and cherry-picked to `3.5`.
--
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
mjsax merged PR #13615:
URL: https://github.com/apache/kafka/pull/13615
--
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
mjsax commented on PR #13592:
URL: https://github.com/apache/kafka/pull/13592#issuecomment-1520757094
Merged to `trunk` and cherry-picked to `3.5` and `3.4` branches.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
cadonna commented on code in PR #13621:
URL: https://github.com/apache/kafka/pull/13621#discussion_r1175663484
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java:
##
@@ -2602,23 +2608,21 @@ public void shouldUpdateInputPartitionsAfterRebal
jeffkbkim commented on PR #13600:
URL: https://github.com/apache/kafka/pull/13600#issuecomment-1520740394
i see a different error now
```
[2023-04-24T17:51:21.714Z] FAILURE: Build failed with an exception.
[2023-04-24T17:51:21.714Z]
[2023-04-24T17:51:21.714Z] * What w
jeffkbkim commented on PR #13602:
URL: https://github.com/apache/kafka/pull/13602#issuecomment-1520737975
the build looks to be successful
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the spec
cmccabe commented on code in PR #13407:
URL: https://github.com/apache/kafka/pull/13407#discussion_r1175718263
##
metadata/src/main/java/org/apache/kafka/controller/metrics/ControllerMetadataMetricsPublisher.java:
##
@@ -115,6 +115,9 @@ private void publishDelta(MetadataDelta de
cmccabe commented on code in PR #13407:
URL: https://github.com/apache/kafka/pull/13407#discussion_r1175717268
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -1123,29 +1165,104 @@ private void claim(int epoch) {
// Prepend the act
mjsax commented on code in PR #13533:
URL: https://github.com/apache/kafka/pull/13533#discussion_r1175716345
##
streams/src/test/java/org/apache/kafka/streams/integration/NamedTopologyIntegrationTest.java:
##
@@ -543,6 +543,16 @@ public void
shouldAllowRemovingAndAddingNamedTop
[
https://issues.apache.org/jira/browse/KAFKA-14862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-14862:
Affects Version/s: 3.1.0
> Outer stream-stream join does not output all results with multi
cmccabe commented on code in PR #13407:
URL: https://github.com/apache/kafka/pull/13407#discussion_r1175710520
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -869,19 +906,30 @@ public CompletableFuture
acceptBatch(List recordBatch)
cmccabe commented on code in PR #13407:
URL: https://github.com/apache/kafka/pull/13407#discussion_r1175709187
##
core/src/test/scala/unit/kafka/server/BrokerRegistrationRequestTest.scala:
##
@@ -145,25 +146,29 @@ class BrokerRegistrationRequestTest {
}
@ClusterTest(clus
mjsax merged PR #13592:
URL: https://github.com/apache/kafka/pull/13592
--
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
cmccabe commented on code in PR #13407:
URL: https://github.com/apache/kafka/pull/13407#discussion_r1175709187
##
core/src/test/scala/unit/kafka/server/BrokerRegistrationRequestTest.scala:
##
@@ -145,25 +146,29 @@ class BrokerRegistrationRequestTest {
}
@ClusterTest(clus
cmccabe commented on code in PR #13407:
URL: https://github.com/apache/kafka/pull/13407#discussion_r1175709047
##
core/src/test/scala/integration/kafka/zk/ZkMigrationIntegrationTest.scala:
##
@@ -324,4 +329,29 @@ class ZkMigrationIntegrationTest {
assertTrue(firstProducer
mjsax commented on code in PR #13622:
URL: https://github.com/apache/kafka/pull/13622#discussion_r1175694673
##
docs/streams/core-concepts.html:
##
@@ -328,13 +328,17 @@ <
for stateful operations such as aggregations and joins, however,
out-of-order data could cause th
rreddy-22 commented on code in PR #13443:
URL: https://github.com/apache/kafka/pull/13443#discussion_r1175703194
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/RangeAssignor.java:
##
@@ -0,0 +1,261 @@
+/*
+ * Licensed to the Apache Software Founda
rreddy-22 commented on code in PR #13443:
URL: https://github.com/apache/kafka/pull/13443#discussion_r1175701652
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/RangeAssignor.java:
##
@@ -0,0 +1,261 @@
+/*
+ * Licensed to the Apache Software Founda
mumrah commented on code in PR #13407:
URL: https://github.com/apache/kafka/pull/13407#discussion_r1175698954
##
core/src/test/scala/unit/kafka/server/BrokerRegistrationRequestTest.scala:
##
@@ -145,25 +146,29 @@ class BrokerRegistrationRequestTest {
}
@ClusterTest(clust
rreddy-22 commented on code in PR #13443:
URL: https://github.com/apache/kafka/pull/13443#discussion_r1175689958
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/RangeAssignor.java:
##
@@ -0,0 +1,261 @@
+/*
+ * Licensed to the Apache Software Founda
[
https://issues.apache.org/jira/browse/KAFKA-14927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17715940#comment-17715940
]
Colin McCabe commented on KAFKA-14927:
--
I haven't verified this but I would expect
[
https://issues.apache.org/jira/browse/KAFKA-14049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee reassigned KAFKA-14049:
--
Assignee: Philip Nee
> Relax Non Null Requirement for KStreamGlobalKTable Left Join
> ---
jeffkbkim commented on PR #13603:
URL: https://github.com/apache/kafka/pull/13603#issuecomment-1520578217
test are unrelated
```
Build / JDK 8 and Scala 2.12 / testDescribeQuorumRequestToBrokers() –
kafka.server.KRaftClusterTest
31s
Build / JDK 8 and Scala 2.12 / testUpdateMetada
jeffkbkim commented on PR #13601:
URL: https://github.com/apache/kafka/pull/13601#issuecomment-1520572197
this one as well
```
[2023-04-24T15:00:18.297Z] FAILURE: Build failed with an exception.
[2023-04-24T15:00:18.297Z]
[2023-04-24T15:00:18.297Z] * What went wrong:
jeffkbkim commented on PR #13600:
URL: https://github.com/apache/kafka/pull/13600#issuecomment-1520571706
@dajac i'm seeing
```
[2023-04-24T15:00:10.166Z] FAILURE: Build failed with an exception.
[2023-04-24T15:00:10.166Z]
[2023-04-24T15:00:10.166Z] * What went wrong:
rreddy-22 commented on code in PR #13443:
URL: https://github.com/apache/kafka/pull/13443#discussion_r1175567311
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/RangeAssignor.java:
##
@@ -0,0 +1,261 @@
+/*
+ * Licensed to the Apache Software Founda
jolshan opened a new pull request, #13632:
URL: https://github.com/apache/kafka/pull/13632
There were too many blocker bugs so it is easier to revert for this release.
Revert was clean.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementat
[
https://issues.apache.org/jira/browse/KAFKA-14931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-14931:
---
Description: We have too many blockers for this commit to work well, so in
the interest of c
[
https://issues.apache.org/jira/browse/KAFKA-14931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan updated KAFKA-14931:
---
Affects Version/s: 3.5.0
> Revert KAFKA-14561 in 3.5
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-14884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan updated KAFKA-14884:
---
Affects Version/s: 3.6.0
(was: 3.5.0)
> Include check transaction
[
https://issues.apache.org/jira/browse/KAFKA-14920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan updated KAFKA-14920:
---
Affects Version/s: 3.6.0
> Address timeouts and out of order sequences
> ---
[
https://issues.apache.org/jira/browse/KAFKA-14916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan updated KAFKA-14916:
---
Affects Version/s: 3.6.0
> Fix code that assumes transactional ID implies all records are tr
Justine Olshan created KAFKA-14931:
--
Summary: Revert KAFKA-14561 in 3.5
Key: KAFKA-14931
URL: https://issues.apache.org/jira/browse/KAFKA-14931
Project: Kafka
Issue Type: Task
Re
mumrah commented on PR #13257:
URL: https://github.com/apache/kafka/pull/13257#issuecomment-1520515387
@mimaison i'm fairly occupied with #13407 and #13461 at the moment, but
could probably find time for this PR in between things this week or next.
Come to think of it, I'll need to g
rreddy-22 commented on code in PR #13443:
URL: https://github.com/apache/kafka/pull/13443#discussion_r1175552910
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/RangeAssignor.java:
##
@@ -0,0 +1,261 @@
+/*
+ * Licensed to the Apache Software Founda
Hello team,
- We are using the zookeeper less Kafka (kafka Kraft).
- The cluster is having 3 nodes.
- One of the nodes gets automatically shut down randomly.
- Checked the logs but didn't get the exact reason.
- Kafka version - 3.3.1
- Attaching the log files.
- Time - 2023
urbandan commented on code in PR #13429:
URL: https://github.com/apache/kafka/pull/13429#discussion_r1175425019
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/OffsetSyncStore.java:
##
@@ -139,10 +171,103 @@ public void close() {
protected void handleRecord(
mumrah commented on code in PR #13631:
URL: https://github.com/apache/kafka/pull/13631#discussion_r1175362654
##
metadata/src/main/java/org/apache/kafka/metadata/migration/KRaftMigrationDriver.java:
##
@@ -134,8 +139,7 @@ private void initializeMigrationState() {
}
p
[
https://issues.apache.org/jira/browse/KAFKA-14918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17715852#comment-17715852
]
Mickael Maison commented on KAFKA-14918:
[~mumrah] The associated PR is merged,
mimaison commented on PR #13257:
URL: https://github.com/apache/kafka/pull/13257#issuecomment-1520246270
@mumrah Let me know if you don't have time to finish this PR. We should
merge this to trunk and backport to 3.5.
--
This is an automated message from the Apache Git Service.
To respon
mimaison commented on code in PR #13257:
URL: https://github.com/apache/kafka/pull/13257#discussion_r1175352627
##
docs/ops.html:
##
@@ -3550,22 +3550,220 @@ Deploying
Considerations
-Kafka server's process.role should be set to either
broker or controller but not bo
dajac commented on code in PR #13443:
URL: https://github.com/apache/kafka/pull/13443#discussion_r1175273145
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/RangeAssignor.java:
##
@@ -0,0 +1,261 @@
+/*
+ * Licensed to the Apache Software Foundation
[
https://issues.apache.org/jira/browse/KAFKA-14925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison resolved KAFKA-14925.
Resolution: Fixed
> The website shouldn't load external resources
> --
[
https://issues.apache.org/jira/browse/KAFKA-14925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17715804#comment-17715804
]
ASF GitHub Bot commented on KAFKA-14925:
mimaison merged PR #506:
URL: https://g
[
https://issues.apache.org/jira/browse/KAFKA-14630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-14630:
-
Fix Version/s: 3.5.0
> Update zstd-jni version to 1.5.5
>
>
>
[
https://issues.apache.org/jira/browse/KAFKA-14630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya resolved KAFKA-14630.
--
Assignee: Ismael Juma (was: Divij Vaidya)
Resolution: Fixed
> Update zstd-jni version t
[
https://issues.apache.org/jira/browse/KAFKA-14630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-14630:
-
Summary: Update zstd-jni version to 1.5.5 (was: Update zstd-jni version to
1.5.2-5)
> Update z
yashmayya commented on PR #13594:
URL: https://github.com/apache/kafka/pull/13594#issuecomment-1520127170
@vamossagar12 the behavior in `MemoryOffsetBackingStore` should probably be
changed - if it fails to shutdown cleanly and throws an exception, it'll cause
further resource closures to b
[
https://issues.apache.org/jira/browse/KAFKA-14630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17715783#comment-17715783
]
Divij Vaidya commented on KAFKA-14630:
--
This was merged in
https://github.com/apac
hudeqi commented on PR #13617:
URL: https://github.com/apache/kafka/pull/13617#issuecomment-1520104888
Hello, Guozhang, please review if you have time. @guozhangwang
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
hudeqi commented on PR #13473:
URL: https://github.com/apache/kafka/pull/13473#issuecomment-1520101597
> Hello, can you help to review this PR? @mimaison
and pin here @mimaison
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
hudeqi commented on PR #13571:
URL: https://github.com/apache/kafka/pull/13571#issuecomment-1520098448
> @hudeqi Thanks for the PR and KIP. The KIP has to be discussed and voted
by the community. See the process section in
https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+
showuon opened a new pull request, #13631:
URL: https://github.com/apache/kafka/pull/13631
1. add `ZkMigrationReady` in apiVersionsResponse
2. check all nodes if `ZkMigrationReady` are ready before moving to next
migration state
### Committer Checklist (excluded from commit message
viktorsomogyi commented on code in PR #13594:
URL: https://github.com/apache/kafka/pull/13594#discussion_r1175222973
##
connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaStatusBackingStoreFormatTest.java:
##
@@ -216,7 +216,7 @@ public void putTopicStateRetriabl
mimaison commented on PR #13571:
URL: https://github.com/apache/kafka/pull/13571#issuecomment-1520050947
@hudeqi Thanks for the PR and KIP. The KIP has to be discussed and voted by
the community. See the process section in
https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+
machi1990 commented on code in PR #13135:
URL: https://github.com/apache/kafka/pull/13135#discussion_r1175200643
##
clients/src/main/java/org/apache/kafka/common/utils/ChunkedBytesStream.java:
##
@@ -0,0 +1,357 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under on
C0urante commented on code in PR #13429:
URL: https://github.com/apache/kafka/pull/13429#discussion_r1175123889
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/OffsetSyncStore.java:
##
@@ -139,10 +171,103 @@ public void close() {
protected void handleRecord(
C0urante commented on code in PR #13429:
URL: https://github.com/apache/kafka/pull/13429#discussion_r1174698662
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/OffsetSyncStore.java:
##
@@ -25,17 +25,46 @@
import org.apache.kafka.common.utils.Utils;
import org.a
urbandan commented on code in PR #13429:
URL: https://github.com/apache/kafka/pull/13429#discussion_r1175076558
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/OffsetSyncStore.java:
##
@@ -139,10 +171,103 @@ public void close() {
protected void handleRecord(
mimaison commented on PR #13259:
URL: https://github.com/apache/kafka/pull/13259#issuecomment-1519845506
Thanks for the updates!
There's a spotbugs failure:
```
Bug type EQ_DOESNT_OVERRIDE_EQUALS
In class org.apache.kafka.connect.runtime.InternalSinkRecord
EQ_DOESNT_OVE
clolov commented on code in PR #13538:
URL: https://github.com/apache/kafka/pull/13538#discussion_r1175040697
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/ConsumerGroupMember.java:
##
@@ -0,0 +1,613 @@
+/*
+ * Licensed to the Apache Software Fou
[
https://issues.apache.org/jira/browse/KAFKA-14909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen reassigned KAFKA-14909:
-
Assignee: Luke Chen
> KRaft Controllers not setting ZkMigrationReady tagged field
> ---
chia7712 merged PR #13630:
URL: https://github.com/apache/kafka/pull/13630
--
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 #13620:
URL: https://github.com/apache/kafka/pull/13620#issuecomment-1519754399
> I think we should be backported to 3.5 too
see #13630
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
chia7712 opened a new pull request, #13630:
URL: https://github.com/apache/kafka/pull/13630
backport #13620 to branch-3.5
--
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
chia7712 merged PR #13620:
URL: https://github.com/apache/kafka/pull/13620
--
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-14712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-14712:
---
Fix Version/s: 3.6.0
(was: 3.5.0)
> Confusing error when writing down
[
https://issues.apache.org/jira/browse/KAFKA-14712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17715669#comment-17715669
]
Mickael Maison commented on KAFKA-14712:
The ticket is still unassigned so movin
[
https://issues.apache.org/jira/browse/KAFKA-14632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-14632:
---
Fix Version/s: 3.6.0
(was: 3.5.0)
> Compression optimization: Remove
[
https://issues.apache.org/jira/browse/KAFKA-14632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17715666#comment-17715666
]
Mickael Maison commented on KAFKA-14632:
PR is still a draft so moving to the ne
[
https://issues.apache.org/jira/browse/KAFKA-14186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-14186:
---
Fix Version/s: 3.6.0
(was: 3.5.0)
> Add unit tests for BatchFileWrite
[
https://issues.apache.org/jira/browse/KAFKA-14186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17715660#comment-17715660
]
Mickael Maison commented on KAFKA-14186:
I can't see a PR and we're near code fr
[
https://issues.apache.org/jira/browse/KAFKA-14839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17715657#comment-17715657
]
Atul Sharma commented on KAFKA-14839:
-
Hi, [~mjsax] can i work in this?
> Exclude p
[
https://issues.apache.org/jira/browse/KAFKA-14876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yash Mayya updated KAFKA-14876:
---
Description:
Add public documentation for the new Kafka Connect offset management REST API
being in
[
https://issues.apache.org/jira/browse/KAFKA-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17715656#comment-17715656
]
Mickael Maison commented on KAFKA-14302:
The ticket is still unassigned so movin
[
https://issues.apache.org/jira/browse/KAFKA-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-14302:
---
Fix Version/s: 3.6.0
(was: 3.5.0)
> Infinite probing rebalance if a c
[
https://issues.apache.org/jira/browse/KAFKA-6527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-6527:
--
Fix Version/s: 3.6.0
(was: 3.5.0)
> Transient failure in DynamicBrokerRe
1 - 100 of 122 matches
Mail list logo