rreddy-22 commented on code in PR #15717:
URL: https://github.com/apache/kafka/pull/15717#discussion_r1573016609
##
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/assignor/ServerSideAssignorBenchmark.java:
##
@@ -0,0 +1,252 @@
+/*
+ * Licensed to the Apache Software
rreddy-22 commented on code in PR #15717:
URL: https://github.com/apache/kafka/pull/15717#discussion_r1572735673
##
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/assignor/ServerSideAssignorBenchmark.java:
##
@@ -0,0 +1,252 @@
+/*
+ * Licensed to the Apache Software
mumrah commented on code in PR #15744:
URL: https://github.com/apache/kafka/pull/15744#discussion_r1572780325
##
core/src/main/scala/kafka/zk/KafkaZkClient.scala:
##
@@ -467,13 +470,33 @@ class KafkaZkClient private[zk] (zooKeeperClient:
ZooKeeperClient, isSecure: Boo
*
emitskevich-blp commented on PR #15722:
URL: https://github.com/apache/kafka/pull/15722#issuecomment-2067299812
> we should verify the non-deprecated metrics should have correct doc which
is not marked as "deprecated". Also, that is what you try to fix, right?
Correct, this is the
jeqo commented on code in PR #15379:
URL: https://github.com/apache/kafka/pull/15379#discussion_r1572995864
##
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/field/MultiFieldPaths.java:
##
@@ -0,0 +1,581 @@
+/*
+ * Licensed to the Apache Software
rreddy-22 commented on code in PR #15717:
URL: https://github.com/apache/kafka/pull/15717#discussion_r1573016246
##
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/assignor/ServerSideAssignorBenchmark.java:
##
@@ -0,0 +1,252 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/KAFKA-16493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839100#comment-17839100
]
Phuc Hong Tran commented on KAFKA-16493:
[~lianetm] I’ll come back to this ticket this weekend
chia7712 commented on code in PR #15758:
URL: https://github.com/apache/kafka/pull/15758#discussion_r1572897153
##
clients/src/test/java/org/apache/kafka/clients/ClientUtilsTest.java:
##
@@ -61,7 +61,7 @@ public void testParseAndValidateAddressesWithReverseLookup() {
chia7712 commented on PR #15569:
URL: https://github.com/apache/kafka/pull/15569#issuecomment-2067222576
The failed test `testParseAndValidateAddressesWithReverseLookup` will get
fixed by #15758. I will merge this PR
--
This is an automated message from the Apache Git Service.
To respond
cmccabe commented on code in PR #15744:
URL: https://github.com/apache/kafka/pull/15744#discussion_r1572716567
##
core/src/main/scala/kafka/zk/KafkaZkClient.scala:
##
@@ -467,13 +470,33 @@ class KafkaZkClient private[zk] (zooKeeperClient:
ZooKeeperClient, isSecure: Boo
*
cmccabe commented on code in PR #15744:
URL: https://github.com/apache/kafka/pull/15744#discussion_r1572716567
##
core/src/main/scala/kafka/zk/KafkaZkClient.scala:
##
@@ -467,13 +470,33 @@ class KafkaZkClient private[zk] (zooKeeperClient:
ZooKeeperClient, isSecure: Boo
*
cmccabe commented on code in PR #15744:
URL: https://github.com/apache/kafka/pull/15744#discussion_r1572722514
##
core/src/main/scala/kafka/zk/KafkaZkClient.scala:
##
@@ -467,13 +470,33 @@ class KafkaZkClient private[zk] (zooKeeperClient:
ZooKeeperClient, isSecure: Boo
*
chia7712 commented on PR #15136:
URL: https://github.com/apache/kafka/pull/15136#issuecomment-2067228882
the failed `testParseAndValidateAddressesWithReverseLookup` is traced by
#15758. will merge it
--
This is an automated message from the Apache Git Service.
To respond to the message,
Chia-Ping Tsai created KAFKA-16589:
--
Summary: Consider removing `ClusterInstance#createAdminClient`
since callers are not sure whether they need to call close
Key: KAFKA-16589
URL:
chia7712 merged PR #15136:
URL: https://github.com/apache/kafka/pull/15136
--
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:
[
https://issues.apache.org/jira/browse/KAFKA-16082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839107#comment-17839107
]
Chia-Ping Tsai commented on KAFKA-16082:
[~gnarula] Could you file PR for branch 3.7?
> Broker
[
https://issues.apache.org/jira/browse/KAFKA-16493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839096#comment-17839096
]
Lianet Magrans commented on KAFKA-16493:
Hey [~phuctran], any progress on this one? Even though
[
https://issues.apache.org/jira/browse/KAFKA-16493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-16493:
---
Fix Version/s: 3.8.0
(was: 4.0.0)
> Avoid unneeded subscription
AndrewJSchofield commented on code in PR #15691:
URL: https://github.com/apache/kafka/pull/15691#discussion_r1572845716
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CompletedFetch.java:
##
@@ -311,25 +312,33 @@ ConsumerRecord parseRecord(Deserializers
mumrah commented on PR #15744:
URL: https://github.com/apache/kafka/pull/15744#issuecomment-2067204988
Updated to include a CheckOp on the `/controller` ZNode. We don't both using
the controller epoch since it is not straightforward to consistently read the
controller and controller epoch
chia7712 commented on PR #15719:
URL: https://github.com/apache/kafka/pull/15719#issuecomment-2067224991
@brandboat please fix the conflicts, thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
chia7712 merged PR #15569:
URL: https://github.com/apache/kafka/pull/15569
--
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:
akatona84 commented on code in PR #15758:
URL: https://github.com/apache/kafka/pull/15758#discussion_r1572917082
##
clients/src/test/java/org/apache/kafka/clients/ClientUtilsTest.java:
##
@@ -61,7 +61,7 @@ public void testParseAndValidateAddressesWithReverseLookup() {
mumrah commented on code in PR #15744:
URL: https://github.com/apache/kafka/pull/15744#discussion_r1572801229
##
core/src/main/scala/kafka/zk/KafkaZkClient.scala:
##
@@ -467,13 +470,33 @@ class KafkaZkClient private[zk] (zooKeeperClient:
ZooKeeperClient, isSecure: Boo
*
rreddy-22 commented on code in PR #15717:
URL: https://github.com/apache/kafka/pull/15717#discussion_r1572726906
##
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/assignor/ServerSideAssignorBenchmark.java:
##
@@ -0,0 +1,266 @@
+/*
+ * Licensed to the Apache Software
mumrah commented on code in PR #15744:
URL: https://github.com/apache/kafka/pull/15744#discussion_r1572777334
##
core/src/main/scala/kafka/zk/KafkaZkClient.scala:
##
@@ -467,13 +470,33 @@ class KafkaZkClient private[zk] (zooKeeperClient:
ZooKeeperClient, isSecure: Boo
*
mumrah commented on code in PR #15744:
URL: https://github.com/apache/kafka/pull/15744#discussion_r1572776248
##
core/src/test/scala/integration/kafka/zk/ZkMigrationIntegrationTest.scala:
##
@@ -950,16 +980,47 @@ class ZkMigrationIntegrationTest {
[
https://issues.apache.org/jira/browse/KAFKA-16486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-16486.
-
Fix Version/s: 3.8.0
Resolution: Done
> Integrate metric measurability changes
cmccabe commented on code in PR #15744:
URL: https://github.com/apache/kafka/pull/15744#discussion_r1572717868
##
core/src/main/scala/kafka/zk/KafkaZkClient.scala:
##
@@ -467,13 +470,33 @@ class KafkaZkClient private[zk] (zooKeeperClient:
ZooKeeperClient, isSecure: Boo
*
rreddy-22 commented on code in PR #15717:
URL: https://github.com/apache/kafka/pull/15717#discussion_r1572729047
##
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/assignor/TargetAssignmentBuilderBenchmark.java:
##
@@ -0,0 +1,202 @@
+/*
+ * Licensed to the Apache Software
mjsax merged PR #15682:
URL: https://github.com/apache/kafka/pull/15682
--
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:
chia7712 commented on code in PR #15679:
URL: https://github.com/apache/kafka/pull/15679#discussion_r1572912365
##
tools/src/test/java/org/apache/kafka/tools/consumer/group/DeleteOffsetsConsumerGroupCommandIntegrationTest.java:
##
@@ -16,7 +16,15 @@
*/
package
[
https://issues.apache.org/jira/browse/KAFKA-16588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839170#comment-17839170
]
PoAn Yang commented on KAFKA-16588:
---
Hi [~chia7712], I'm interested in this. May I assign to myself?
[
https://issues.apache.org/jira/browse/KAFKA-15585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Calvin Liu resolved KAFKA-15585.
Resolution: Fixed
> DescribeTopic API
> -
>
> Key: KAFKA-15585
>
omkreddy commented on code in PR #15656:
URL: https://github.com/apache/kafka/pull/15656#discussion_r1573153281
##
server/src/main/java/org/apache/kafka/server/config/KafkaSecurityConfigs.java:
##
@@ -0,0 +1,239 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
rreddy-22 commented on code in PR #15717:
URL: https://github.com/apache/kafka/pull/15717#discussion_r1573016246
##
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/assignor/ServerSideAssignorBenchmark.java:
##
@@ -0,0 +1,252 @@
+/*
+ * Licensed to the Apache Software
infantlikesprogramming commented on PR #15696:
URL: https://github.com/apache/kafka/pull/15696#issuecomment-2067538939
@chia7712 Thanks for the reply. I have tried the following code and received
the results. Each time I run the code, the `DescribeTopicsResult` gives a
different
showuon commented on code in PR #15732:
URL: https://github.com/apache/kafka/pull/15732#discussion_r1572018203
##
metadata/src/test/java/org/apache/kafka/metadata/migration/KRaftMigrationDriverTest.java:
##
@@ -881,10 +937,18 @@ public List> recordBatches() {
showuon commented on code in PR #15732:
URL: https://github.com/apache/kafka/pull/15732#discussion_r1572018955
##
metadata/src/test/java/org/apache/kafka/metadata/migration/KRaftMigrationDriverTest.java:
##
@@ -881,10 +937,18 @@ public List> recordBatches() {
chia7712 commented on PR #15569:
URL: https://github.com/apache/kafka/pull/15569#issuecomment-2066120621
```
[2024-04-18T17:26:16.149Z] [ant:checkstyle] [ERROR]
brandboat commented on PR #15719:
URL: https://github.com/apache/kafka/pull/15719#issuecomment-2066136873
> @brandboat this PR is great. However, I'd like to merge it after
https://github.com/apache/kafka/pull/15569.
https://github.com/apache/kafka/pull/15569 is a huge PR which refactor
chia7712 commented on PR #15719:
URL: https://github.com/apache/kafka/pull/15719#issuecomment-2066133702
@brandboat this PR is great. However, I'd like to merge it after #15569.
#15569 is a huge PR which refactor the `KafkaConfig` and `LogConfig`, and I try
to alleviate the pain of fixing
[
https://issues.apache.org/jira/browse/KAFKA-15709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838923#comment-17838923
]
Zihao Lin commented on KAFKA-15709:
---
[~mdedetrich] feel free to take over
> KRaft support in
lucasbru merged PR #15753:
URL: https://github.com/apache/kafka/pull/15753
--
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:
lucasbru commented on PR #15738:
URL: https://github.com/apache/kafka/pull/15738#issuecomment-2066195894
LGTM, thanks!
Merging this, however:
* Have we discussed the behavioral difference with broker team / David?
* Have we documented the behavioral difference anywhere?
--
lucasbru commented on code in PR #15613:
URL: https://github.com/apache/kafka/pull/15613#discussion_r1572109503
##
core/src/test/scala/integration/kafka/api/PlaintextConsumerCommitTest.scala:
##
@@ -304,6 +304,64 @@ class PlaintextConsumerCommitTest extends
aaron-ai commented on PR #15728:
URL: https://github.com/apache/kafka/pull/15728#issuecomment-2066221145
KIP has been created here:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-1039%3A+Disable+automatic+topic+creation+for+MirrorMaker2+consumers
--
This is an automated message
chia7712 commented on code in PR #15745:
URL: https://github.com/apache/kafka/pull/15745#discussion_r1572122943
##
core/src/test/java/kafka/test/junit/ClusterTestExtensions.java:
##
@@ -179,8 +186,8 @@ private void processClusterTest(ExtensionContext context,
ClusterTest
[
https://issues.apache.org/jira/browse/KAFKA-15963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838883#comment-17838883
]
Josep Prat commented on KAFKA-15963:
it failed again but 3.6-IV1 this time:
mimaison commented on PR #15756:
URL: https://github.com/apache/kafka/pull/15756#issuecomment-2066023794
Hi @mfvitale, thanks for the PR!
This is adding new configurations to transformations so this will require a
showuon commented on PR #15616:
URL: https://github.com/apache/kafka/pull/15616#issuecomment-2066130114
@johnnychhsu , do you have any other comments? I'll merge this at the
weekend if no other comments. Thanks.
--
This is an automated message from the Apache Git Service.
To respond to
FrankYang0529 commented on PR #15745:
URL: https://github.com/apache/kafka/pull/15745#issuecomment-2066132584
Hi @gaurav-narula and @chia7712, I have addressed all comments. Thanks for
your review.
--
This is an automated message from the Apache Git Service.
To respond to the message,
chia7712 commented on code in PR #15745:
URL: https://github.com/apache/kafka/pull/15745#discussion_r1572064864
##
core/src/test/java/kafka/test/junit/ClusterTestExtensions.java:
##
@@ -179,8 +186,8 @@ private void processClusterTest(ExtensionContext context,
ClusterTest
funky-eyes commented on code in PR #15625:
URL: https://github.com/apache/kafka/pull/15625#discussion_r1572073595
##
core/src/main/java/kafka/log/remote/quota/RLMQuotaManager.java:
##
Review Comment:
I have a question, in fact, what this PR does is to provide a standard
lucasbru merged PR #15738:
URL: https://github.com/apache/kafka/pull/15738
--
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:
lucasbru commented on code in PR #15613:
URL: https://github.com/apache/kafka/pull/15613#discussion_r1572109078
##
core/src/test/scala/integration/kafka/api/PlaintextConsumerCommitTest.scala:
##
@@ -304,6 +304,64 @@ class PlaintextConsumerCommitTest extends
mfvitale commented on PR #15756:
URL: https://github.com/apache/kafka/pull/15756#issuecomment-2066045097
> Hi @mfvitale, thanks for the PR! This is adding new configurations to
transformations so this will require a
hudeqi opened a new pull request, #15757:
URL: https://github.com/apache/kafka/pull/15757
A clear hint meaning error: The actual logic is that an error is thrown only
when the high watermark lags behind the epoch start offset, but the hint
meaning is opposite.
--
This is an automated
FrankYang0529 commented on code in PR #15745:
URL: https://github.com/apache/kafka/pull/15745#discussion_r1572114481
##
core/src/test/java/kafka/test/junit/ClusterTestExtensions.java:
##
@@ -179,8 +186,8 @@ private void processClusterTest(ExtensionContext context,
ClusterTest
Ritika Reddy created KAFKA-16587:
Summary: Store subscription model for consumer group in group state
Key: KAFKA-16587
URL: https://issues.apache.org/jira/browse/KAFKA-16587
Project: Kafka
jlprat merged PR #13824:
URL: https://github.com/apache/kafka/pull/13824
--
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:
[
https://issues.apache.org/jira/browse/KAFKA-15146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838877#comment-17838877
]
Josep Prat commented on KAFKA-15146:
Another instance here:
showuon commented on code in PR #15732:
URL: https://github.com/apache/kafka/pull/15732#discussion_r1571963909
##
metadata/src/main/java/org/apache/kafka/metadata/migration/KRaftMigrationDriver.java:
##
@@ -786,12 +773,29 @@ public void run() throws Exception {
}
[
https://issues.apache.org/jira/browse/KAFKA-12511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838878#comment-17838878
]
Josep Prat commented on KAFKA-12511:
Another instance:
[
https://issues.apache.org/jira/browse/KAFKA-8250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838882#comment-17838882
]
Josep Prat commented on KAFKA-8250:
---
Another instance:
[
https://issues.apache.org/jira/browse/KAFKA-12319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838881#comment-17838881
]
Josep Prat commented on KAFKA-12319:
Another instance:
[
https://issues.apache.org/jira/browse/KAFKA-14453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838880#comment-17838880
]
Josep Prat commented on KAFKA-14453:
Another instance:
jlprat commented on PR #13824:
URL: https://github.com/apache/kafka/pull/13824#issuecomment-2065886831
All tests failing for this build were known flaky tests. Merging
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
chia7712 commented on PR #15679:
URL: https://github.com/apache/kafka/pull/15679#issuecomment-2065947030
> Do you think that we should revert unstable.api.versions.enable change and
try again? Thanks.
Yep
--
This is an automated message from the Apache Git Service.
To respond to
[
https://issues.apache.org/jira/browse/KAFKA-15926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838879#comment-17838879
]
Josep Prat commented on KAFKA-15926:
Another instance:
showuon commented on code in PR #15732:
URL: https://github.com/apache/kafka/pull/15732#discussion_r1571981454
##
metadata/src/main/java/org/apache/kafka/metadata/migration/KRaftMigrationDriver.java:
##
@@ -786,12 +773,29 @@ public void run() throws Exception {
}
cadonna commented on PR #15613:
URL: https://github.com/apache/kafka/pull/15613#issuecomment-2066478507
> > @lucasbru Thanks for the PR!
> > The unit tests you added fail in the build and also for me locally.
> > Plus, I have a question regarding the integration tests.
>
>
akatona84 commented on PR #15758:
URL: https://github.com/apache/kafka/pull/15758#issuecomment-2066418336
now the ipv6 address is changed to 2606:2800:220:1:248:1893:25c8:1946...
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
mumrah commented on PR #15754:
URL: https://github.com/apache/kafka/pull/15754#issuecomment-2066454711
```
SESSION REPORT (ALL TESTS)
ducktape version: 0.11.4
session_id: 2024-04-18--017
[
https://issues.apache.org/jira/browse/KAFKA-16585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838979#comment-17838979
]
Stanislav Spiridonov commented on KAFKA-16585:
--
The case is relatively simple. I have
soarez commented on code in PR #15744:
URL: https://github.com/apache/kafka/pull/15744#discussion_r1572295590
##
core/src/test/scala/integration/kafka/zk/ZkMigrationIntegrationTest.scala:
##
@@ -950,16 +980,47 @@ class ZkMigrationIntegrationTest {
cadonna commented on code in PR #15613:
URL: https://github.com/apache/kafka/pull/15613#discussion_r1572290394
##
core/src/test/scala/integration/kafka/api/PlaintextConsumerCommitTest.scala:
##
@@ -304,6 +304,64 @@ class PlaintextConsumerCommitTest extends
AbstractConsumerTest
dajac commented on code in PR #15717:
URL: https://github.com/apache/kafka/pull/15717#discussion_r1572307205
##
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/assignor/ServerSideAssignorBenchmark.java:
##
@@ -0,0 +1,252 @@
+/*
+ * Licensed to the Apache Software Foundation
lianetm commented on PR #15738:
URL: https://github.com/apache/kafka/pull/15738#issuecomment-2066577956
Hey @lucasbru , answering your questions : the new behaviour of the static
membership regarding a member that joins with dup group instance Id is
documented in
OmniaGM commented on code in PR #15728:
URL: https://github.com/apache/kafka/pull/15728#discussion_r1572155918
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java:
##
@@ -169,6 +170,7 @@ static Map sourceConsumerConfig(Map props) {
chia7712 commented on PR #15616:
URL: https://github.com/apache/kafka/pull/15616#issuecomment-2066277923
This PR is good but it seems to me `LogSegment` should NOT guess the
directory structure managed by upper class (i.e `LogManager`).
It seems the root cause is caused by following
showuon commented on code in PR #15744:
URL: https://github.com/apache/kafka/pull/15744#discussion_r1572140166
##
core/src/main/scala/kafka/zk/KafkaZkClient.scala:
##
@@ -467,13 +470,33 @@ class KafkaZkClient private[zk] (zooKeeperClient:
ZooKeeperClient, isSecure: Boo
*
OmniaGM commented on PR #15728:
URL: https://github.com/apache/kafka/pull/15728#issuecomment-2066275194
Thanks for getting the KIP out there for discussion and for fixing the
tests. Should this PR be a draft until we have the KIP voted in by the
community?
--
This is an automated
chia7712 commented on PR #15722:
URL: https://github.com/apache/kafka/pull/15722#issuecomment-2066283854
> Effectively, such test would verify the behavior of deprecated method.
What do you think?
we should verify the non-deprecated metrics should have correct doc which is
not
FrankYang0529 commented on code in PR #15745:
URL: https://github.com/apache/kafka/pull/15745#discussion_r1572189143
##
core/src/test/java/kafka/test/junit/ClusterTestExtensions.java:
##
@@ -179,8 +186,8 @@ private void processClusterTest(ExtensionContext context,
ClusterTest
lucasbru commented on PR #15613:
URL: https://github.com/apache/kafka/pull/15613#issuecomment-2066392315
> @lucasbru Thanks for the PR!
>
> The unit tests you added fail in the build and also for me locally.
>
> Plus, I have a question regarding the integration tests.
aaron-ai commented on PR #15728:
URL: https://github.com/apache/kafka/pull/15728#issuecomment-2066276867
> Thanks for getting the KIP out there for discussion and for fixing the
tests. Should this PR be a draft until we have the KIP voted in by the
community?
OK
--
This is an
akatona84 opened a new pull request, #15758:
URL: https://github.com/apache/kafka/pull/15758
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade
lianetm commented on code in PR #15753:
URL: https://github.com/apache/kafka/pull/15753#discussion_r1572508072
##
tests/kafkatest/tests/client/consumer_rolling_upgrade_test.py:
##
@@ -56,12 +56,7 @@ def _verify_roundrobin_assignment(self, consumer):
jeqo commented on code in PR #15379:
URL: https://github.com/apache/kafka/pull/15379#discussion_r1572509302
##
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/field/FieldPathNotationTest.java:
##
@@ -0,0 +1,149 @@
+/*
+ * Licensed to the Apache Software
lucasbru commented on code in PR #15753:
URL: https://github.com/apache/kafka/pull/15753#discussion_r1572534438
##
tests/kafkatest/tests/client/consumer_rolling_upgrade_test.py:
##
@@ -56,12 +56,7 @@ def _verify_roundrobin_assignment(self, consumer):
lucasbru merged PR #15594:
URL: https://github.com/apache/kafka/pull/15594
--
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:
soarez commented on code in PR #15732:
URL: https://github.com/apache/kafka/pull/15732#discussion_r1572550218
##
metadata/src/main/java/org/apache/kafka/metadata/migration/KRaftMigrationDriver.java:
##
@@ -786,12 +773,29 @@ public void run() throws Exception {
}
}
soarez commented on code in PR #15732:
URL: https://github.com/apache/kafka/pull/15732#discussion_r1572557807
##
metadata/src/main/java/org/apache/kafka/metadata/migration/KRaftMigrationDriver.java:
##
@@ -786,12 +773,29 @@ public void run() throws Exception {
}
}
lianetm commented on code in PR #15753:
URL: https://github.com/apache/kafka/pull/15753#discussion_r1572569170
##
tests/kafkatest/tests/client/consumer_rolling_upgrade_test.py:
##
@@ -56,12 +56,7 @@ def _verify_roundrobin_assignment(self, consumer):
lianetm commented on code in PR #15753:
URL: https://github.com/apache/kafka/pull/15753#discussion_r1572569170
##
tests/kafkatest/tests/client/consumer_rolling_upgrade_test.py:
##
@@ -56,12 +56,7 @@ def _verify_roundrobin_assignment(self, consumer):
akatona84 commented on PR #15758:
URL: https://github.com/apache/kafka/pull/15758#issuecomment-2066839773
ipv6 alternates between 2606:2800:21f:cb07:6820:80da:af6b:8b2c and the old
one, it's hard to fix the test like this.
--
This is an automated message from the Apache Git Service.
dajac commented on code in PR #15717:
URL: https://github.com/apache/kafka/pull/15717#discussion_r1572314707
##
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/assignor/ServerSideAssignorBenchmark.java:
##
@@ -0,0 +1,266 @@
+/*
+ * Licensed to the Apache Software Foundation
jeqo commented on code in PR #15379:
URL: https://github.com/apache/kafka/pull/15379#discussion_r1572436483
##
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/ValueToKeyTest.java:
##
@@ -60,6 +62,30 @@ public void schemaless() {
mdedetrich commented on PR #13375:
URL: https://github.com/apache/kafka/pull/13375#issuecomment-2066602056
@yashmayya Are you still working on this to get it over the finish line or
is it okay for me to take over?
--
This is an automated message from the Apache Git Service.
To respond to
1 - 100 of 107 matches
Mail list logo