flashmouse commented on code in PR #13920:
URL: https://github.com/apache/kafka/pull/13920#discussion_r1274457186
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignorTest.java:
##
@@ -724,6 +725,90 @@ public void
testLargeAssignmentAndGrou
[
https://issues.apache.org/jira/browse/KAFKA-15254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nikita resolved KAFKA-15254.
Resolution: Duplicate
> Task is not stopped until the poll interval passes in case of task restarting.
> -
[
https://issues.apache.org/jira/browse/KAFKA-15255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nikita resolved KAFKA-15255.
Resolution: Duplicate
> Task is not stopped until the poll interval passes in case of task restarting.
> -
[
https://issues.apache.org/jira/browse/KAFKA-15253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nikita resolved KAFKA-15253.
Resolution: Duplicate
> Task is not stopped until the poll interval passes in case of task restarting.
> -
Nikita created KAFKA-15255:
--
Summary: Task is not stopped until the poll interval passes in
case of task restarting.
Key: KAFKA-15255
URL: https://issues.apache.org/jira/browse/KAFKA-15255
Project: Kafka
Nikita created KAFKA-15253:
--
Summary: Task is not stopped until the poll interval passes in
case of task restarting.
Key: KAFKA-15253
URL: https://issues.apache.org/jira/browse/KAFKA-15253
Project: Kafka
Nikita created KAFKA-15254:
--
Summary: Task is not stopped until the poll interval passes in
case of task restarting.
Key: KAFKA-15254
URL: https://issues.apache.org/jira/browse/KAFKA-15254
Project: Kafka
Nikita created KAFKA-15252:
--
Summary: Task is not stopped until the poll interval passes in
case of task restarting.
Key: KAFKA-15252
URL: https://issues.apache.org/jira/browse/KAFKA-15252
Project: Kafka
dajac closed pull request #13998: KAFKA-14702: Extend server side assignor to
support rack aware replica placement
URL: https://github.com/apache/kafka/pull/13998
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
[
https://issues.apache.org/jira/browse/KAFKA-15239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen reassigned KAFKA-15239:
-
Assignee: Federico Valeri
> producerPerformance system test for old client failed after v3.5.0
[
https://issues.apache.org/jira/browse/KAFKA-15239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747302#comment-17747302
]
Luke Chen commented on KAFKA-15239:
---
Thanks [~fvaleri] ! Assigning to you now.
> prod
ex172000 commented on code in PR #14093:
URL: https://github.com/apache/kafka/pull/14093#discussion_r1274426209
##
connect/runtime/src/main/java/org/apache/kafka/connect/converters/BooleanConverterConfig.java:
##
@@ -25,13 +25,13 @@
*/
public class BooleanConverterConfig exte
[
https://issues.apache.org/jira/browse/KAFKA-15223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747266#comment-17747266
]
kaushik srinivas commented on KAFKA-15223:
--
Any updates on this ?
> Need more
olalamichelle commented on PR #14078:
URL: https://github.com/apache/kafka/pull/14078#issuecomment-1650957681
@divijvaidya Sorry It is my first time trying to contribute to Kafka. I
didn't see any error log with the build failure. Could you help review the PR
and give me some guidance on ho
[
https://issues.apache.org/jira/browse/KAFKA-14049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747261#comment-17747261
]
Philip Nee commented on KAFKA-14049:
[~aki] - please do!
> Relax Non Null Requireme
[
https://issues.apache.org/jira/browse/KAFKA-14049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747259#comment-17747259
]
Florin Akermann commented on KAFKA-14049:
-
Hi, [~pnee]
I work on https://issue
[
https://issues.apache.org/jira/browse/KAFKA-14049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Florin Akermann reassigned KAFKA-14049:
---
Assignee: Florin Akermann (was: Philip Nee)
> Relax Non Null Requirement for KStre
[
https://issues.apache.org/jira/browse/KAFKA-13197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Florin Akermann reassigned KAFKA-13197:
---
Assignee: Florin Akermann
> KStream-GlobalKTable join semantics don't match documen
flashmouse commented on code in PR #13920:
URL: https://github.com/apache/kafka/pull/13920#discussion_r1274341109
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignorTest.java:
##
@@ -724,6 +725,90 @@ public void
testLargeAssignmentAndGrou
github-actions[bot] commented on PR #12782:
URL: https://github.com/apache/kafka/pull/12782#issuecomment-1650925567
This PR is being marked as stale since it has not had any activity in 90
days. If you would like to keep this PR alive, please ask a committer for
review. If the PR has merge
[
https://issues.apache.org/jira/browse/KAFKA-15218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen resolved KAFKA-15218.
---
Fix Version/s: 3.6.0
Resolution: Fixed
> NPE will be thrown while deleting topic and fetch fr
showuon merged PR #14051:
URL: https://github.com/apache/kafka/pull/14051
--
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.
showuon commented on PR #14051:
URL: https://github.com/apache/kafka/pull/14051#issuecomment-1650851531
Thanks @vamossagar12 !
--
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
showuon commented on PR #14051:
URL: https://github.com/apache/kafka/pull/14051#issuecomment-1650850675
Finally had a comfortable test results:
```
Build / JDK 11 and Scala 2.13 /
org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationExactlyOnceTest.testOffsetTrans
DL1231 commented on PR #13947:
URL: https://github.com/apache/kafka/pull/13947#issuecomment-1650824472
@kamalcph
Sure, I appreciate your feedback on the PR. Please go ahead and collaborate
with me on the changes. You can push the remaining changes from your
KAFKA-15130 branch to my
jolshan commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1274240171
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/OffsetMetadataManagerTest.java:
##
@@ -0,0 +1,1113 @@
+/*
+ * Licensed to the Apache Software Foun
jolshan commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1274240171
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/OffsetMetadataManagerTest.java:
##
@@ -0,0 +1,1113 @@
+/*
+ * Licensed to the Apache Software Foun
jolshan commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1274237674
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/OffsetMetadataManagerTest.java:
##
@@ -0,0 +1,1113 @@
+/*
+ * Licensed to the Apache Software Foun
jolshan commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1274235539
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/OffsetMetadataManagerTest.java:
##
@@ -0,0 +1,1113 @@
+/*
+ * Licensed to the Apache Software Foun
jolshan commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1274232061
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/OffsetMetadataManagerTest.java:
##
@@ -0,0 +1,1113 @@
+/*
+ * Licensed to the Apache Software Foun
jolshan commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1274232061
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/OffsetMetadataManagerTest.java:
##
@@ -0,0 +1,1113 @@
+/*
+ * Licensed to the Apache Software Foun
[
https://issues.apache.org/jira/browse/KAFKA-15235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747217#comment-17747217
]
Said BOUDJELDA commented on KAFKA-15235:
[~ethaden] Please let me know more abo
jolshan commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1274227661
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/generic/GenericGroupTest.java:
##
@@ -956,6 +961,72 @@ public void testMaybeElectNewJoinedLeaderCh
[
https://issues.apache.org/jira/browse/KAFKA-15097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Said BOUDJELDA reassigned KAFKA-15097:
--
Assignee: Said BOUDJELDA
> NoSuchFileException in LogCleaner Operation.
> ---
[
https://issues.apache.org/jira/browse/KAFKA-15097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747212#comment-17747212
]
Said BOUDJELDA commented on KAFKA-15097:
I really want to take this ticket and s
[
https://issues.apache.org/jira/browse/KAFKA-12317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747210#comment-17747210
]
Matthias J. Sax commented on KAFKA-12317:
-
Thanks for picking it up – I think it
mjsax commented on PR #13909:
URL: https://github.com/apache/kafka/pull/13909#issuecomment-1650680240
Yes, that the class I was referring, too. -- I don't know the detail from
top of my head, but I am sure if you read the code you can figure it out. Let
us know if you have any questions.
Matthias J. Sax created KAFKA-15251:
---
Summary: Upgrade system test to use 3.5.1
Key: KAFKA-15251
URL: https://issues.apache.org/jira/browse/KAFKA-15251
Project: Kafka
Issue Type: Test
mjsax commented on PR #12988:
URL: https://github.com/apache/kafka/pull/12988#issuecomment-1650677564
Thanks! Great to hear.
--
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.
jeffkbkim commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1274185328
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java:
##
@@ -0,0 +1,454 @@
+/*
+ * Licensed to the Apache Software Foundat
rreddy-22 opened a new pull request, #14099:
URL: https://github.com/apache/kafka/pull/14099
We want to make the assignors rack aware and in order to obtain and provide
the rack Information the following interface modifications were made:-
SubcribedTopicDescribor - Interface passed to
jeffkbkim commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1274182711
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java:
##
@@ -0,0 +1,454 @@
+/*
+ * Licensed to the Apache Software Foundat
jeffkbkim commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1274173286
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java:
##
@@ -0,0 +1,454 @@
+/*
+ * Licensed to the Apache Software Foundat
bmscomp opened a new pull request, #14098:
URL: https://github.com/apache/kafka/pull/14098
Upgrade the version of `Gradle` versions plugin, to version 0.47.0 is a too
minor change that have no affect on the build process or design, nor
documentation, but I can see it's very important to kee
jolshan commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1274178895
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java:
##
@@ -0,0 +1,454 @@
+/*
+ * Licensed to the Apache Software Foundatio
jolshan commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1274177883
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/generic/GenericGroup.java:
##
@@ -738,6 +742,84 @@ public String generateMemberId(String clientId,
jolshan commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1274175859
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/generic/GenericGroup.java:
##
@@ -738,6 +742,84 @@ public String generateMemberId(String clientId,
jolshan commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1274174772
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/ConsumerGroup.java:
##
@@ -497,6 +499,30 @@ public DeadlineAndEpoch metadataRefreshDeadli
jolshan commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1274168232
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/ReplicatedGroupCoordinator.java:
##
@@ -239,6 +283,14 @@ public void replay(Record record) throws
jolshan commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1274166277
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/ReplicatedGroupCoordinator.java:
##
@@ -193,6 +217,22 @@ public CoordinatorResult genericGroupJoin
mjsax commented on PR #14085:
URL: https://github.com/apache/kafka/pull/14085#issuecomment-1650617474
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 #14085:
URL: https://github.com/apache/kafka/pull/14085
--
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
jeffkbkim commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1274158029
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java:
##
@@ -0,0 +1,454 @@
+/*
+ * Licensed to the Apache Software Foundat
jeffkbkim commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1274154502
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java:
##
@@ -471,9 +472,48 @@ public CompletableFuture
commitOffsets(
lihaosky opened a new pull request, #14097:
URL: https://github.com/apache/kafka/pull/14097
## Description
Update `ClientTagAwareStandbyTaskAssignor` to take functional params so that
we can pass custom tags from racks.
## Testing
Unit test
--
This is an automated message
jolshan commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1274140048
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/Utils.java:
##
@@ -0,0 +1,40 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
jolshan commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1274140048
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/Utils.java:
##
@@ -0,0 +1,40 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
jolshan commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1274139408
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetAndMetadata.java:
##
@@ -114,12 +116,29 @@ public static OffsetAndMetadata fromRecord(
jeffkbkim commented on code in PR #14056:
URL: https://github.com/apache/kafka/pull/14056#discussion_r1274116830
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java:
##
@@ -368,9 +369,29 @@ public CompletableFuture heartbeat(
jolshan commented on code in PR #14090:
URL: https://github.com/apache/kafka/pull/14090#discussion_r1274109070
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntime.java:
##
@@ -1053,50 +1066,80 @@ private void enqueue(CoordinatorEvent
jolshan commented on code in PR #14090:
URL: https://github.com/apache/kafka/pull/14090#discussion_r1274107844
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntime.java:
##
@@ -1053,50 +1066,80 @@ private void enqueue(CoordinatorEvent
jolshan commented on code in PR #14090:
URL: https://github.com/apache/kafka/pull/14090#discussion_r1274094726
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntimeTest.java:
##
@@ -970,14 +970,15 @@ public void testClose() throws Excep
jolshan commented on code in PR #14090:
URL: https://github.com/apache/kafka/pull/14090#discussion_r1274093513
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntime.java:
##
@@ -1187,63 +1230,62 @@ public void scheduleLoadOperation(
jolshan commented on code in PR #14090:
URL: https://github.com/apache/kafka/pull/14090#discussion_r1274089957
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntime.java:
##
@@ -1187,63 +1230,62 @@ public void scheduleLoadOperation(
jeffkbkim commented on code in PR #14017:
URL: https://github.com/apache/kafka/pull/14017#discussion_r1274089242
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -8539,5 +8379,20 @@ private static class RebalanceResult {
jolshan commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1274067065
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java:
##
@@ -0,0 +1,454 @@
+/*
+ * Licensed to the Apache Software Foundatio
jeffkbkim commented on code in PR #14017:
URL: https://github.com/apache/kafka/pull/14017#discussion_r1274066264
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -5524,5 +5670,2897 @@ private static Record newGroupMetadat
jolshan commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1274065371
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java:
##
@@ -0,0 +1,454 @@
+/*
+ * Licensed to the Apache Software Foundatio
ahuang98 commented on PR #14084:
URL: https://github.com/apache/kafka/pull/14084#issuecomment-1650480884
Combined, the last two runs look good. Test failures look to be unrelated.
https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-14084/1/tests
https://
mumrah merged PR #14062:
URL: https://github.com/apache/kafka/pull/14062
--
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
nizhikov opened a new pull request, #14096:
URL: https://github.com/apache/kafka/pull/14096
This PR contains migration `AdminUtils` and `BrokerMetadata` classes to java.
These classes used in `ReassignPartitionsCommand` which are subject to
rewrite in #13247
### Committer Checklis
bbejeck commented on PR #13987:
URL: https://github.com/apache/kafka/pull/13987#issuecomment-1650430142
@Cerchie since it's been a couple of weeks for this PR can you rebase this
with trunk?
Pending the related tests passing we should be able to merge
ping @vvcephei for a quick se
dajac commented on code in PR #14056:
URL: https://github.com/apache/kafka/pull/14056#discussion_r1273976287
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java:
##
@@ -368,9 +369,29 @@ public CompletableFuture heartbeat(
dajac commented on code in PR #14017:
URL: https://github.com/apache/kafka/pull/14017#discussion_r1273993761
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java:
##
@@ -330,9 +330,30 @@ public CompletableFuture syncGroup(
dajac commented on code in PR #14017:
URL: https://github.com/apache/kafka/pull/14017#discussion_r1273964395
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -5524,5 +5670,2897 @@ private static Record newGroupMetadataRec
dajac commented on code in PR #14017:
URL: https://github.com/apache/kafka/pull/14017#discussion_r1273962781
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -8539,5 +8379,20 @@ private static class RebalanceResult {
[
https://issues.apache.org/jira/browse/KAFKA-15250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee updated KAFKA-15250:
---
Parent: KAFKA-14246
Issue Type: Sub-task (was: Bug)
> DefaultBackgroundThread is running ti
Philip Nee created KAFKA-15250:
--
Summary: DefaultBackgroundThread is running tight loop
Key: KAFKA-15250
URL: https://issues.apache.org/jira/browse/KAFKA-15250
Project: Kafka
Issue Type: Bug
dajac commented on code in PR #14017:
URL: https://github.com/apache/kafka/pull/14017#discussion_r1273960665
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -5524,5 +5670,2897 @@ private static Record newGroupMetadataRec
dajac commented on code in PR #14017:
URL: https://github.com/apache/kafka/pull/14017#discussion_r1273959151
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -5524,5 +5670,2897 @@ private static Record newGroupMetadataRec
dajac commented on code in PR #14017:
URL: https://github.com/apache/kafka/pull/14017#discussion_r1273958096
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -5524,5 +5670,2897 @@ private static Record newGroupMetadataRec
dajac commented on code in PR #14017:
URL: https://github.com/apache/kafka/pull/14017#discussion_r1273957238
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -5524,5 +5670,2897 @@ private static Record newGroupMetadataRec
dajac commented on code in PR #14017:
URL: https://github.com/apache/kafka/pull/14017#discussion_r1273954244
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -5524,5 +5670,2897 @@ private static Record newGroupMetadataRec
dajac commented on code in PR #14017:
URL: https://github.com/apache/kafka/pull/14017#discussion_r1273952844
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -5524,5 +5670,2897 @@ private static Record newGroupMetadataRec
dajac commented on code in PR #14017:
URL: https://github.com/apache/kafka/pull/14017#discussion_r1273950275
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -5205,11 +5245,102 @@ public void
testReplaceStaticMemberInSta
dajac commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1273942395
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java:
##
@@ -0,0 +1,454 @@
+/*
+ * Licensed to the Apache Software Foundation
vamossagar12 commented on PR #13801:
URL: https://github.com/apache/kafka/pull/13801#issuecomment-1650338567
Regarding
> Can we skip writes for tombstone records to the secondary store in our
second write (the one that takes place after we've written to the primary
store)? It's a bi
vamossagar12 commented on code in PR #13801:
URL: https://github.com/apache/kafka/pull/13801#discussion_r1273932710
##
connect/runtime/src/main/java/org/apache/kafka/connect/storage/ConnectorOffsetBackingStore.java:
##
@@ -279,8 +284,51 @@ public Future set(Map
values, Callback
jeffkbkim commented on code in PR #14017:
URL: https://github.com/apache/kafka/pull/14017#discussion_r1273929393
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -5524,5 +5670,2897 @@ private static Record newGroupMetadat
kirktrue opened a new pull request, #14095:
URL: https://github.com/apache/kafka/pull/14095
*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 testin
kirktrue commented on PR #13990:
URL: https://github.com/apache/kafka/pull/13990#issuecomment-1650291166
@junrao in the logs for the JDK 11 run, I see this:
```
> Task :clients:testClasses
Unexpected exception thrown.
org.gradle.internal.remote.internal.MessageIOException: Cou
omkreddy commented on PR #14094:
URL: https://github.com/apache/kafka/pull/14094#issuecomment-1650257506
@sciclon2 Thanks, Can you try add/update test here:
https://github.com/apache/kafka/blob/trunk/core/src/test/scala/unit/kafka/server/AlterUserScramCredentialsRequestTest.scala#L251
--
[
https://issues.apache.org/jira/browse/KAFKA-15243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747081#comment-17747081
]
Sergio Troiano commented on KAFKA-15243:
[~omkreddy] , thanks, PR open
https://
sciclon2 opened a new pull request, #14094:
URL: https://github.com/apache/kafka/pull/14094
This PR aims to fix a bug, basically there is a mismatch between the Kafka
users and the list tool output.
Kafka allows to create users with special characters that are encoded before
stor
[
https://issues.apache.org/jira/browse/KAFKA-15191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747079#comment-17747079
]
Bryan commented on KAFKA-15191:
---
Strong interest from my perspective for end-to-end visibi
gharris1727 commented on PR #14089:
URL: https://github.com/apache/kafka/pull/14089#issuecomment-1650218495
> should we expand the scope of how PluginDesc objects can be compared?
Yes, this is a good idea. I could feel that something was wrong when I had
to double-cast the dissimilar
gharris1727 commented on code in PR #14089:
URL: https://github.com/apache/kafka/pull/14089#discussion_r1273845134
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginDesc.java:
##
@@ -115,6 +115,10 @@ public int compareTo(PluginDesc other) {
junrao commented on PR #13990:
URL: https://github.com/apache/kafka/pull/13990#issuecomment-1650204432
@kirktrue : For JDK 11 tests, it seems that there were 2 checkstyle failures
`:clients:checkstyleTest`and `:server-common:checkstyleTest`.
--
This is an automated message from th
cmccabe commented on code in PR #13643:
URL: https://github.com/apache/kafka/pull/13643#discussion_r1273720728
##
raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java:
##
@@ -2394,6 +2394,11 @@ public Optional latestSnapshotId() {
return log.latestSnapshotId();
[
https://issues.apache.org/jira/browse/KAFKA-15200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Abhinav Tripathi reassigned KAFKA-15200:
Assignee: Abhinav Tripathi
> verify pre-requisite at start of release.py
> --
1 - 100 of 166 matches
Mail list logo
