[
https://issues.apache.org/jira/browse/KAFKA-16250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Calvin Liu updated KAFKA-16250:
---
Description:
The current coordinator does not validate the offset commits before persisting
it in
johnnychhsu commented on code in PR #15861:
URL: https://github.com/apache/kafka/pull/15861#discussion_r1592759299
##
core/src/test/java/kafka/test/ClusterConfig.java:
##
@@ -153,15 +148,19 @@ public Map>
perBrokerOverrideProperties() {
return
[
https://issues.apache.org/jira/browse/KAFKA-16656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844368#comment-17844368
]
Chris Egerton commented on KAFKA-16656:
---
Hi [~leninjoseph] it should be possible to use a custom
viktorsomogyi commented on PR #15697:
URL: https://github.com/apache/kafka/pull/15697#issuecomment-2098821932
@soarez at the end I chose the shortcut regarding detecting leaders before
shutdown. The reason is complex as the solution that would be required for this
is complex too.
So on
[
https://issues.apache.org/jira/browse/KAFKA-16108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844365#comment-17844365
]
Igor Soarez commented on KAFKA-16108:
-
[~ChrisEgerton] is this still relevant? The priority field is
raminqaf commented on PR #15601:
URL: https://github.com/apache/kafka/pull/15601#issuecomment-2098817942
@gharris1727 Thanks for the feedback! I reverted all the changes you
requested and reverted a couple of other indentation problems that caused a
diff. I can even go further and revert &
Gaurav Narula created KAFKA-16686:
-
Summary: Flakey tests in TopicBasedRemoteLogMetadataManagerTest
Key: KAFKA-16686
URL: https://issues.apache.org/jira/browse/KAFKA-16686
Project: Kafka
cadonna commented on code in PR #15408:
URL: https://github.com/apache/kafka/pull/15408#discussion_r1592700226
##
core/src/test/scala/integration/kafka/api/PlaintextConsumerCallbackTest.scala:
##
@@ -0,0 +1,138 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under
FrankYang0529 commented on code in PR #15868:
URL: https://github.com/apache/kafka/pull/15868#discussion_r1592700292
##
connect/runtime/src/test/java/org/apache/kafka/connect/integration/SessionedProtocolIntegrationTest.java:
##
@@ -115,11 +112,11 @@ public void
FrankYang0529 commented on code in PR #15868:
URL: https://github.com/apache/kafka/pull/15868#discussion_r1592697934
##
connect/runtime/src/test/java/org/apache/kafka/connect/integration/SessionedProtocolIntegrationTest.java:
##
@@ -115,11 +112,11 @@ public void
[
https://issues.apache.org/jira/browse/KAFKA-16681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-16681:
--
Assignee: PoAn Yang (was: Chia-Ping Tsai)
> Rewrite MiniKDC by Java
>
[
https://issues.apache.org/jira/browse/KAFKA-13329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton resolved KAFKA-13329.
---
Fix Version/s: 3.8.0
Resolution: Fixed
> Connect does not perform preflight
[
https://issues.apache.org/jira/browse/KAFKA-13328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton resolved KAFKA-13328.
---
Fix Version/s: 3.8.0
Resolution: Fixed
> Connect does not perform preflight
[
https://issues.apache.org/jira/browse/KAFKA-16681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844345#comment-17844345
]
PoAn Yang commented on KAFKA-16681:
---
Hi [~chia7712], I'm interested in this. If you are not working on
C0urante merged PR #14309:
URL: https://github.com/apache/kafka/pull/14309
--
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:
jolshan commented on PR #15837:
URL: https://github.com/apache/kafka/pull/15837#issuecomment-2098727340
Sorry I was out of town (at KSB). I will try to take a look today, but
thanks Luke for approving as well :)
--
This is an automated message from the Apache Git Service.
To respond to
C0urante commented on PR #14309:
URL: https://github.com/apache/kafka/pull/14309#issuecomment-2098726331
Thanks @gharris1727. I've reverted the changes to `Utils.java` and verified
locally with tests. Everything else looked okay on the previous CI run, going
to merge.
--
This is an
gharris1727 commented on code in PR #15601:
URL: https://github.com/apache/kafka/pull/15601#discussion_r1591293880
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java:
##
@@ -184,20 +146,34 @@ public void process(final Record record) {
FrankYang0529 commented on PR #15821:
URL: https://github.com/apache/kafka/pull/15821#issuecomment-2098714976
Hi @chia7712, I rebase latest trunk branch, so we have
`ConsumerGroupCommandTestUtils` now. The only remaining part is
`SimpleConsumerGroupExecutor`. This is used by
C0urante commented on code in PR #14309:
URL: https://github.com/apache/kafka/pull/14309#discussion_r1592678706
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java:
##
@@ -392,6 +399,146 @@ protected Map
FrankYang0529 commented on code in PR #15872:
URL: https://github.com/apache/kafka/pull/15872#discussion_r1592664550
##
tools/src/test/java/org/apache/kafka/tools/consumer/group/DeleteOffsetsConsumerGroupCommandIntegrationTest.java:
##
@@ -88,7 +113,7 @@ public void
chia7712 commented on code in PR #15868:
URL: https://github.com/apache/kafka/pull/15868#discussion_r1592649000
##
connect/runtime/src/test/java/org/apache/kafka/connect/integration/SessionedProtocolIntegrationTest.java:
##
@@ -115,11 +112,11 @@ public void
KevinZTW opened a new pull request, #15884:
URL: https://github.com/apache/kafka/pull/15884
Merge the unit test functions down to the class of integration test to avoid
two test class under the same file
### Committer Checklist (excluded from commit message)
- [ ] Verify
[
https://issues.apache.org/jira/browse/KAFKA-16645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844334#comment-17844334
]
Igor Soarez commented on KAFKA-16645:
-
The vulnerability report flags {{libexpat}} version
dajac opened a new pull request, #15883:
URL: https://github.com/apache/kafka/pull/15883
This PR is still WIP. I am still playing with an alternative approach.
Trunk:
```
Benchmark (assignmentType)
(assignorType) (isRackAware)
chia7712 commented on code in PR #15863:
URL: https://github.com/apache/kafka/pull/15863#discussion_r1592508554
##
core/src/main/scala/kafka/log/LogCleaner.scala:
##
@@ -101,6 +101,7 @@ class LogCleaner(initialConfig: CleanerConfig,
time: Time = Time.SYSTEM)
chiacyu commented on code in PR #15863:
URL: https://github.com/apache/kafka/pull/15863#discussion_r1592516715
##
core/src/main/scala/kafka/log/LogCleaner.scala:
##
@@ -159,6 +159,7 @@ class LogCleaner(initialConfig: CleanerConfig,
cleaners += cleaner
chiacyu commented on code in PR #15863:
URL: https://github.com/apache/kafka/pull/15863#discussion_r1592509827
##
core/src/main/scala/kafka/log/LogCleaner.scala:
##
@@ -182,6 +183,27 @@ class LogCleaner(initialConfig: CleanerConfig,
cleanerManager.removeMetrics()
Review
[
https://issues.apache.org/jira/browse/KAFKA-16307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-16307.
-
Fix Version/s: 3.8.0
Reviewer: David Jacot
Resolution: Fixed
> fix
dajac merged PR #15835:
URL: https://github.com/apache/kafka/pull/15835
--
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:
cadonna opened a new pull request, #15882:
URL: https://github.com/apache/kafka/pull/15882
Uses the new remove operation of the state updater that returns
a future to handle task assignment.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and
frankvicky opened a new pull request, #15881:
URL: https://github.com/apache/kafka/pull/15881
Check all uses of `TestUtils#resource` and replace with `scala.util.Using`
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify
jeqo opened a new pull request, #15880:
URL: https://github.com/apache/kafka/pull/15880
[KAFKA-16685]
--
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,
[
https://issues.apache.org/jira/browse/KAFKA-16685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jorge Esteban Quilcate Otoya updated KAFKA-16685:
-
Summary: RLMTask warning logs do not include parent exception
[
https://issues.apache.org/jira/browse/KAFKA-16685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jorge Esteban Quilcate Otoya updated KAFKA-16685:
-
Summary: RLMTask warn logs do not include parent exception trace
[
https://issues.apache.org/jira/browse/KAFKA-16685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jorge Esteban Quilcate Otoya updated KAFKA-16685:
-
Description:
When RLMTask warning exceptions happen and are
Jorge Esteban Quilcate Otoya created KAFKA-16685:
Summary: RSM Task warn logs do not include parent exception trace
Key: KAFKA-16685
URL: https://issues.apache.org/jira/browse/KAFKA-16685
cadonna merged PR #15870:
URL: https://github.com/apache/kafka/pull/15870
--
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:
AyoubOm commented on code in PR #15607:
URL: https://github.com/apache/kafka/pull/15607#discussion_r1592389047
##
streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinIntegrationTest.java:
##
@@ -244,21 +248,21 @@ public void
AyoubOm commented on code in PR #15607:
URL: https://github.com/apache/kafka/pull/15607#discussion_r1592386867
##
streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinIntegrationTest.java:
##
@@ -244,21 +248,21 @@ public void
AyoubOm commented on code in PR #15607:
URL: https://github.com/apache/kafka/pull/15607#discussion_r1592386867
##
streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinIntegrationTest.java:
##
@@ -244,21 +248,21 @@ public void
[
https://issues.apache.org/jira/browse/KAFKA-16682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-16682:
--
Assignee: TengYao Chi (was: Chia-Ping Tsai)
> Rewrite JassTestUtils by Java
>
[
https://issues.apache.org/jira/browse/KAFKA-16682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844261#comment-17844261
]
TengYao Chi commented on KAFKA-16682:
-
I am able to handle this issue.
> Rewrite JassTestUtils by
gongxuanzhang commented on PR #15812:
URL: https://github.com/apache/kafka/pull/15812#issuecomment-2098224856
> Hi @gongxuanzhang and thank you for the contribution!
>
> This is actually an issue in a lot of places, I checked with this
checkstyle.xml rule:
>
> ```
>
frankvicky opened a new pull request, #15879:
URL: https://github.com/apache/kafka/pull/15879
Remove variable "unimplementedquorum" from EndToEndAuthorizationTest.scala
and SaslEndToEndAuthorizationTest.scala
- [ ] Verify design and implementation
- [ ] Verify test coverage and
nizhikov commented on code in PR #15873:
URL: https://github.com/apache/kafka/pull/15873#discussion_r1592313103
##
core/src/test/java/kafka/admin/ConfigCommandUnitTest.java:
##
@@ -410,6 +448,430 @@ public void testOptionEntityTypeNames() {
showuon commented on code in PR #15690:
URL: https://github.com/apache/kafka/pull/15690#discussion_r1592297330
##
storage/src/test/java/org/apache/kafka/tiered/storage/utils/TieredStorageTestUtils.java:
##
@@ -55,7 +57,7 @@ public class TieredStorageTestUtils {
// Log
cadonna commented on code in PR #15871:
URL: https://github.com/apache/kafka/pull/15871#discussion_r1592297149
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -623,6 +623,21 @@ private void addToTasksToClose(final Map> futures,
[
https://issues.apache.org/jira/browse/KAFKA-16684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844251#comment-17844251
]
Chia-Ping Tsai commented on KAFKA-16684:
After
Chia-Ping Tsai created KAFKA-16684:
--
Summary: FetchResponse#responseData could return incorrect data
Key: KAFKA-16684
URL: https://issues.apache.org/jira/browse/KAFKA-16684
Project: Kafka
nizhikov commented on code in PR #15873:
URL: https://github.com/apache/kafka/pull/15873#discussion_r1592249836
##
core/src/test/java/kafka/admin/ConfigCommandUnitTest.java:
##
@@ -418,4 +880,77 @@ public static String[] toArray(String... first) {
public static String[]
[
https://issues.apache.org/jira/browse/KAFKA-12385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844248#comment-17844248
]
Chia-Ping Tsai commented on KAFKA-12385:
It seems to me `FetchResponse#responseData` is a weird
lucasbru commented on code in PR #15871:
URL: https://github.com/apache/kafka/pull/15871#discussion_r1592261128
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -623,6 +623,21 @@ private void addToTasksToClose(final Map> futures,
nizhikov commented on code in PR #15873:
URL: https://github.com/apache/kafka/pull/15873#discussion_r1592249836
##
core/src/test/java/kafka/admin/ConfigCommandUnitTest.java:
##
@@ -418,4 +880,77 @@ public static String[] toArray(String... first) {
public static String[]
nizhikov commented on code in PR #15873:
URL: https://github.com/apache/kafka/pull/15873#discussion_r1592246946
##
core/src/test/java/kafka/admin/ConfigCommandUnitTest.java:
##
@@ -410,6 +448,430 @@ public void testOptionEntityTypeNames() {
clolov commented on PR #15673:
URL: https://github.com/apache/kafka/pull/15673#issuecomment-2097975706
Heya @junrao! Let me know your thoughts on my responses. I have futher
updated the below + rebased. I am waiting on the tests to finish running and if
they uncover something I will aim to
[
https://issues.apache.org/jira/browse/KAFKA-16679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-16679:
--
Assignee: Cheng-Kai, Zhang (was: Chia-Ping Tsai)
> Merge
kamalcph commented on PR #15825:
URL: https://github.com/apache/kafka/pull/15825#issuecomment-2097869168
@junrao @satishd @chia7712 @showuon
Updated the test plan in the summary. Verified that the patch fixes the
issue by running the trunk and patched build. With the fix, the
clolov commented on code in PR #15673:
URL: https://github.com/apache/kafka/pull/15673#discussion_r1592116050
##
clients/src/main/java/org/apache/kafka/common/requests/ListOffsetsRequest.java:
##
@@ -70,7 +70,7 @@ else if (isolationLevel == IsolationLevel.READ_COMMITTED)
clolov commented on code in PR #15673:
URL: https://github.com/apache/kafka/pull/15673#discussion_r1592114443
##
core/src/test/scala/unit/kafka/server/ListOffsetsRequestTest.scala:
##
@@ -219,7 +219,7 @@ class ListOffsetsRequestTest extends BaseRequestTest {
[
https://issues.apache.org/jira/browse/KAFKA-16679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844222#comment-17844222
]
Cheng-Kai, Zhang commented on KAFKA-16679:
--
Hi [~chia7712] , could I work on this one? :D
>
sidyag commented on code in PR #15837:
URL: https://github.com/apache/kafka/pull/15837#discussion_r1592106849
##
core/src/test/scala/unit/kafka/server/KafkaApisTest.scala:
##
@@ -2822,6 +2822,31 @@ class KafkaApisTest extends Logging {
() =>
sidyag commented on code in PR #15837:
URL: https://github.com/apache/kafka/pull/15837#discussion_r1592106849
##
core/src/test/scala/unit/kafka/server/KafkaApisTest.scala:
##
@@ -2822,6 +2822,31 @@ class KafkaApisTest extends Logging {
() =>
AndrewJSchofield opened a new pull request, #15878:
URL: https://github.com/apache/kafka/pull/15878
KIP-714 and KIP-1000 introduced 3 new RPCs. These new RPCs were not added to
docs/security.html to document the authorization checks required to perform the
requests.
While I was
Chia-Ping Tsai created KAFKA-16683:
--
Summary: Extract security-related helpers from scala.TestUtils to
java class
Key: KAFKA-16683
URL: https://issues.apache.org/jira/browse/KAFKA-16683
Project:
[
https://issues.apache.org/jira/browse/KAFKA-16680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-16680:
---
Description:
This is a umbrella issue.
In order to migrate more tests to new test infra,
Chia-Ping Tsai created KAFKA-16682:
--
Summary: Rewrite JassTestUtils by Java
Key: KAFKA-16682
URL: https://issues.apache.org/jira/browse/KAFKA-16682
Project: Kafka
Issue Type: Sub-task
Chia-Ping Tsai created KAFKA-16681:
--
Summary: Rewrite MiniKDC by Java
Key: KAFKA-16681
URL: https://issues.apache.org/jira/browse/KAFKA-16681
Project: Kafka
Issue Type: Sub-task
lucasbru merged PR #15856:
URL: https://github.com/apache/kafka/pull/15856
--
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-16589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-16589:
---
Parent: KAFKA-16680
Issue Type: Sub-task (was: Improvement)
> Consider removing
Chia-Ping Tsai created KAFKA-16680:
--
Summary: Make ClusterTestExtensions support SASL
Key: KAFKA-16680
URL: https://issues.apache.org/jira/browse/KAFKA-16680
Project: Kafka
Issue Type: New
lucasbru commented on PR #15874:
URL: https://github.com/apache/kafka/pull/15874#issuecomment-2097704867
@mjsax It does change, because we need to keep a list of tests (with
parameters) that do not work with ARM. The `from_version` parameter does not
change, because only old versions are
lucasbru commented on code in PR #15870:
URL: https://github.com/apache/kafka/pull/15870#discussion_r1591960681
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -602,6 +608,47 @@ private void removeUnusedTaskFromStateUpdater(final
[
https://issues.apache.org/jira/browse/KAFKA-16677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-16677:
--
Assignee: PoAn Yang (was: Chia-Ping Tsai)
> Replace ClusterType#ALL and
Chia-Ping Tsai created KAFKA-16679:
--
Summary: Merge `DeleteRecordsCommandUnitTest` into
`DeleteRecordsCommandTest`, `FeatureCommandUnitTest` into
Key: KAFKA-16679
URL:
[
https://issues.apache.org/jira/browse/KAFKA-16677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844163#comment-17844163
]
PoAn Yang commented on KAFKA-16677:
---
Hi [~chia7712], I'm interested in this feature. If you're not
[
https://issues.apache.org/jira/browse/KAFKA-16615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-16615.
-
Fix Version/s: 3.8.0
Reviewer: David Jacot
Assignee: Dongnuo Lyu
dajac merged PR #15798:
URL: https://github.com/apache/kafka/pull/15798
--
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-16678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-16678:
--
Assignee: TengYao Chi (was: Chia-Ping Tsai)
> Remove unimplementedquorum from
[
https://issues.apache.org/jira/browse/KAFKA-16678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844157#comment-17844157
]
TengYao Chi commented on KAFKA-16678:
-
I am able to handle this issue.
> Remove unimplementedquorum
Chia-Ping Tsai created KAFKA-16678:
--
Summary: Remove unimplementedquorum from EndToEndAuthorizationTest
Key: KAFKA-16678
URL: https://issues.apache.org/jira/browse/KAFKA-16678
Project: Kafka
chia7712 commented on code in PR #15861:
URL: https://github.com/apache/kafka/pull/15861#discussion_r1591866899
##
core/src/test/java/kafka/test/ClusterConfig.java:
##
@@ -306,11 +300,16 @@ public Builder setPerBrokerProperties(Map> perBroke
return this;
}
chia7712 commented on PR #15861:
URL: https://github.com/apache/kafka/pull/15861#issuecomment-2097528853
As #15766 gets merged now, could you please fix the build error?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
[
https://issues.apache.org/jira/browse/KAFKA-16677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844150#comment-17844150
]
PoAn Yang commented on KAFKA-16677:
---
Hi [~chia7712], I think the feature is good. Most of time, we use
chia7712 merged PR #15851:
URL: https://github.com/apache/kafka/pull/15851
--
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-16677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844148#comment-17844148
]
Chia-Ping Tsai commented on KAFKA-16677:
For another, we can simplify the code
chia7712 commented on code in PR #15875:
URL: https://github.com/apache/kafka/pull/15875#discussion_r1591859505
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java:
##
@@ -1768,7 +1768,7 @@ private boolean
[
https://issues.apache.org/jira/browse/KAFKA-16593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-16593.
Fix Version/s: 3.8.0
Resolution: Fixed
> Rewrite DeleteConsumerGroupsTest by
chia7712 merged PR #15766:
URL: https://github.com/apache/kafka/pull/15766
--
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 #15840:
URL: https://github.com/apache/kafka/pull/15840#discussion_r1591853150
##
core/src/test/java/kafka/admin/ConfigCommandIntegrationTest.java:
##
@@ -171,120 +144,352 @@ public void
testDynamicBrokerConfigUpdateUsingZooKeeper() throws
101 - 190 of 190 matches
Mail list logo
