guozhangwang commented on pull request #8934:
URL: https://github.com/apache/kafka/pull/8934#issuecomment-652202875
@hachikuji Could you take a look at this one since it is a 2.6 blocker?
Another alternative if we are less comfortable with the current exponential
timeout
[
https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17149122#comment-17149122
]
Guozhang Wang commented on KAFKA-10134:
---
I've updated the PR.
> High CPU issue during rebalance
showuon edited a comment on pull request #8712:
URL: https://github.com/apache/kafka/pull/8712#issuecomment-652177809
Thanks for the comments, @abbccdda . I've address your comments in this
commit:
https://github.com/apache/kafka/pull/8712/commits/4b57a606a3834323302b6d3d33ab95e5b88d183b
showuon commented on pull request #8712:
URL: https://github.com/apache/kafka/pull/8712#issuecomment-652177809
Thanks for the comments, @abbccdda . I've address your comments in this
commit:
https://github.com/apache/kafka/pull/8712/commits/4b57a606a3834323302b6d3d33ab95e5b88d183b
showuon commented on a change in pull request #8712:
URL: https://github.com/apache/kafka/pull/8712#discussion_r448103331
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopicManagerTest.java
##
@@ -287,12 +290,124 @@ public void
showuon commented on a change in pull request #8712:
URL: https://github.com/apache/kafka/pull/8712#discussion_r448100930
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopicManagerTest.java
##
@@ -287,12 +290,124 @@ public void
showuon commented on a change in pull request #8712:
URL: https://github.com/apache/kafka/pull/8712#discussion_r448100994
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopicManagerTest.java
##
@@ -287,12 +290,124 @@ public void
vvcephei commented on pull request #8938:
URL: https://github.com/apache/kafka/pull/8938#issuecomment-652173502
I had a chat with @ableegoldman earlier today.
As a general strategy, maybe what we can do is aim to repair the
non-downgradability where it exists. For example, when we
showuon commented on a change in pull request #8712:
URL: https://github.com/apache/kafka/pull/8712#discussion_r448099598
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopicManagerTest.java
##
@@ -287,12 +290,124 @@ public void
showuon commented on a change in pull request #8712:
URL: https://github.com/apache/kafka/pull/8712#discussion_r448099358
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopicManagerTest.java
##
@@ -287,12 +290,124 @@ public void
vvcephei commented on pull request #8938:
URL: https://github.com/apache/kafka/pull/8938#issuecomment-652171893
Oof, looks like I missed "something":
vvcephei commented on pull request #8961:
URL: https://github.com/apache/kafka/pull/8961#issuecomment-652171595
new run:
https://jenkins.confluent.io/job/system-test-kafka-branch-builder/4002/
This is an automated message
vvcephei commented on pull request #8961:
URL: https://github.com/apache/kafka/pull/8961#issuecomment-652168931
Ah, Thanks @kkonstantine ,
I see that now:
```
17:42:20 worker5: + curl --retry-all-errors --retry 5 -s -L
showuon commented on a change in pull request #8712:
URL: https://github.com/apache/kafka/pull/8712#discussion_r448095124
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java
##
@@ -100,13 +100,19 @@ public
guozhangwang commented on a change in pull request #8964:
URL: https://github.com/apache/kafka/pull/8964#discussion_r448093846
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManagerUtil.java
##
@@ -38,13 +41,39 @@
*/
final class
guozhangwang opened a new pull request #8964:
URL: https://github.com/apache/kafka/pull/8964
1. Do not always flush state stores when committing (in post-commit), move
`stateMgr.flush` into post-commit to live with checkpointing. Then in
post-commit, we checkpoint when:
1.a. The
abbccdda commented on pull request #8962:
URL: https://github.com/apache/kafka/pull/8962#issuecomment-652159635
test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
abbccdda commented on pull request #8963:
URL: https://github.com/apache/kafka/pull/8963#issuecomment-652159442
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please
abbccdda commented on pull request #8962:
URL: https://github.com/apache/kafka/pull/8962#issuecomment-652159560
Test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
ableegoldman opened a new pull request #8963:
URL: https://github.com/apache/kafka/pull/8963
The current failures we're seeing with this test are due to faulty
assumptions that it makes and not any real bug in eos-beta (at least, from what
I've seen so far).
The test relies on
mmolimar commented on a change in pull request #7496:
URL: https://github.com/apache/kafka/pull/7496#discussion_r448045788
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java
##
@@ -524,6 +524,26 @@ private SinkRecord
ableegoldman commented on a change in pull request #8962:
URL: https://github.com/apache/kafka/pull/8962#discussion_r448044329
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
##
@@ -136,7 +143,59 @@ private boolean
rhauch commented on a change in pull request #7496:
URL: https://github.com/apache/kafka/pull/7496#discussion_r448029128
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java
##
@@ -524,6 +524,26 @@ private SinkRecord
rhauch commented on a change in pull request #8858:
URL: https://github.com/apache/kafka/pull/8858#discussion_r448023368
##
File path: docs/connect.html
##
@@ -258,6 +258,48 @@ REST
API
GET /- return basic information about the Kafka
Connect cluster such as the
vvcephei commented on pull request #8962:
URL: https://github.com/apache/kafka/pull/8962#issuecomment-652090962
Test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/KAFKA-10217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148994#comment-17148994
]
Sophie Blee-Goldman commented on KAFKA-10217:
-
[~mhmdchebbi] try rebasing – the PR that
kkonstantine removed a comment on pull request #8961:
URL: https://github.com/apache/kafka/pull/8961#issuecomment-652085184
@vvcephei `--retry-all-error` is not an option that the current curl version
recognizes. The system tests fail early on that error.
kkonstantine commented on pull request #8961:
URL: https://github.com/apache/kafka/pull/8961#issuecomment-652085184
@vvcephei `--retry-all-error` is not an option that the current curl version
recognizes. The system tests fail early on that error.
vvcephei commented on pull request #8961:
URL: https://github.com/apache/kafka/pull/8961#issuecomment-652082007
System test meta run:
https://jenkins.confluent.io/job/system-test-kafka-branch-builder/4001/console
This is an
vvcephei commented on pull request #8961:
URL: https://github.com/apache/kafka/pull/8961#issuecomment-652081453
Recently, I have seen a few remote (aws-over-vagrant) system tests fail
during setup due to this error:
```
worker15: + curl -O
ableegoldman opened a new pull request #8962:
URL: https://github.com/apache/kafka/pull/8962
Two more edge cases I found producing extra TaskcorruptedException while
playing around with the failing eos-beta upgrade test (sadly these are
unrelated problems, as the test still fails with
vvcephei opened a new pull request #8961:
URL: https://github.com/apache/kafka/pull/8961
Adds a retry to curl, using the built-in exponential backoff mechanism.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test
kkonstantine commented on pull request #8859:
URL: https://github.com/apache/kafka/pull/8859#issuecomment-652079556
Same here. Thanks for checking!
This is an automated message from the Apache Git Service.
To respond to the
d8tltanc closed pull request #8544:
URL: https://github.com/apache/kafka/pull/8544
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
[
https://issues.apache.org/jira/browse/KAFKA-10217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148976#comment-17148976
]
mohamed chebbi commented on KAFKA-10217:
Hi [~vvcephei]
i can't find
[
https://issues.apache.org/jira/browse/KAFKA-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch reassigned KAFKA-10166:
-
Assignee: Sophie Blee-Goldman
> Excessive TaskCorruptedException seen in testing
>
[
https://issues.apache.org/jira/browse/KAFKA-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman reopened KAFKA-10166:
-
Assignee: (was: Bruno Cadonna)
Found two edge cases we missed earlier so
dajac commented on pull request #8544:
URL: https://github.com/apache/kafka/pull/8544#issuecomment-652059065
@d8tltanc We can close this one.
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/KAFKA-10219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148954#comment-17148954
]
Sachin Kurle commented on KAFKA-10219:
--
I have simple use-case where I read off source topic from
hachikuji opened a new pull request #8960:
URL: https://github.com/apache/kafka/pull/8960
Note this is a backport of (#7687) for 2.3.
Existing producer state expiration uses timestamps from data records only
and not from transaction markers. This can cause premature producer
abbccdda commented on pull request #8431:
URL: https://github.com/apache/kafka/pull/8431#issuecomment-652033261
@maseiler Could you try to attach a screenshot of the fix?
This is an automated message from the Apache Git
abbccdda commented on pull request #6792:
URL: https://github.com/apache/kafka/pull/6792#issuecomment-652030858
Closing the PR due to lack of interest and duplicate.
This is an automated message from the Apache Git Service.
abbccdda closed pull request #6792:
URL: https://github.com/apache/kafka/pull/6792
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
[
https://issues.apache.org/jira/browse/KAFKA-4996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leah Thomas resolved KAFKA-4996.
Resolution: Fixed
> Fix findbugs multithreaded correctness warnings for streams
>
d8tltanc commented on pull request #8846:
URL: https://github.com/apache/kafka/pull/8846#issuecomment-652013968
@skaundinya15 @abbccdda @ijuma
The utility class GeometricProgression is renamed in #8683 and merged into
trunk. Now, this patch is rebased and ready for review.
d8tltanc commented on a change in pull request #8846:
URL: https://github.com/apache/kafka/pull/8846#discussion_r447942236
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/AdminClientConfig.java
##
@@ -67,9 +67,14 @@
* retry.backoff.ms
*/
junrao commented on a change in pull request #8479:
URL: https://github.com/apache/kafka/pull/8479#discussion_r447927722
##
File path: core/src/main/scala/kafka/cluster/Partition.scala
##
@@ -499,7 +500,15 @@ class Partition(val topicPartition: TopicPartition,
[
https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148854#comment-17148854
]
Guozhang Wang commented on KAFKA-10134:
---
[~neowu0] Thanks for your comments. I will incorporate
[
https://issues.apache.org/jira/browse/KAFKA-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10017:
--
Priority: Blocker (was: Critical)
> Flaky Test
[
https://issues.apache.org/jira/browse/KAFKA-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148846#comment-17148846
]
Guozhang Wang commented on KAFKA-10017:
---
[~rhauch] I'm making it back as a blocker for 2.6 since
[
https://issues.apache.org/jira/browse/KAFKA-10219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148818#comment-17148818
]
Boyang Chen commented on KAFKA-10219:
-
Thanks for the proposal, the use case you proposed is
[
https://issues.apache.org/jira/browse/KAFKA-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148801#comment-17148801
]
Di Campo edited comment on KAFKA-4273 at 6/30/20, 4:12 PM:
---
Any news or
[
https://issues.apache.org/jira/browse/KAFKA-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148801#comment-17148801
]
Di Campo commented on KAFKA-4273:
-
Any news or improved workaround? I am also interested on this.
In my
[
https://issues.apache.org/jira/browse/KAFKA-10220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148774#comment-17148774
]
huxihx commented on KAFKA-10220:
Well, from the broker perspective, you are right. Only trunk is
[
https://issues.apache.org/jira/browse/KAFKA-10220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148756#comment-17148756
]
Ismael Juma commented on KAFKA-10220:
-
>From the link you referenced, it seems like this only
[
https://issues.apache.org/jira/browse/KAFKA-10220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148738#comment-17148738
]
huxihx commented on KAFKA-10220:
[~ijuma] This should affect 2.6 as well since `configurationKeys`
[
https://issues.apache.org/jira/browse/KAFKA-10220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen reassigned KAFKA-10220:
-
Assignee: Luke Chen
> NPE when describing resources
> -
>
>
omkreddy commented on pull request #8957:
URL: https://github.com/apache/kafka/pull/8957#issuecomment-651811192
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
omkreddy merged pull request #8958:
URL: https://github.com/apache/kafka/pull/8958
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
[
https://issues.apache.org/jira/browse/KAFKA-10220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148680#comment-17148680
]
Ismael Juma commented on KAFKA-10220:
-
Does this affect 2.6 as well or just trunk?
> NPE when
rajinisivaram opened a new pull request #8959:
URL: https://github.com/apache/kafka/pull/8959
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including
dajac opened a new pull request #8958:
URL: https://github.com/apache/kafka/pull/8958
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade
urbandan opened a new pull request #8957:
URL: https://github.com/apache/kafka/pull/8957
Implements KIP-308
Changes:
- Added kafka-get-offsets.sh script
- Removed deprecated max-wait-ms and offsets arguments
- Updated tool to query all topic-partitions by default
-
omkreddy commented on a change in pull request #8935:
URL: https://github.com/apache/kafka/pull/8935#discussion_r447662323
##
File path: core/src/main/scala/kafka/controller/ControllerEventManager.scala
##
@@ -69,14 +69,16 @@ class QueuedEvent(val event: ControllerEvent,
omkreddy merged pull request #8956:
URL: https://github.com/apache/kafka/pull/8956
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
[
https://issues.apache.org/jira/browse/KAFKA-10220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148576#comment-17148576
]
Edoardo Comar edited comment on KAFKA-10220 at 6/30/20, 11:51 AM:
--
[
https://issues.apache.org/jira/browse/KAFKA-10220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148576#comment-17148576
]
Edoardo Comar edited comment on KAFKA-10220 at 6/30/20, 11:51 AM:
--
[
https://issues.apache.org/jira/browse/KAFKA-10220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148576#comment-17148576
]
Edoardo Comar edited comment on KAFKA-10220 at 6/30/20, 11:50 AM:
--
[
https://issues.apache.org/jira/browse/KAFKA-10220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148576#comment-17148576
]
Edoardo Comar commented on KAFKA-10220:
---
{{also note that if the describe comes from the current
[
https://issues.apache.org/jira/browse/KAFKA-10220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148575#comment-17148575
]
Edoardo Comar commented on KAFKA-10220:
---
ok, a bit more steps to reproduce looks like the
dajac commented on pull request #8954:
URL: https://github.com/apache/kafka/pull/8954#issuecomment-651742771
@ijuma @rajinisivaram Could you review this one when you have time?
This is an automated message from the Apache
itantiger commented on pull request #8753:
URL: https://github.com/apache/kafka/pull/8753#issuecomment-651738671
@rhauch Can you take a look at this?
This is an automated message from the Apache Git Service.
To respond to
dajac commented on a change in pull request #8940:
URL: https://github.com/apache/kafka/pull/8940#discussion_r447557312
##
File path: core/src/test/scala/unit/kafka/server/KafkaApisTest.scala
##
@@ -354,13 +401,62 @@ class KafkaApisTest {
.setValue("bar"))
[
https://issues.apache.org/jira/browse/KAFKA-10220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148564#comment-17148564
]
Edoardo Comar commented on KAFKA-10220:
---
[~huxi_2b] I initially hit this when using the 2.5.0 cli
omkreddy commented on pull request #8935:
URL: https://github.com/apache/kafka/pull/8935#issuecomment-651735737
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/KAFKA-10220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Edoardo Comar updated KAFKA-10220:
--
Description:
In current trunk code
Describing a topic from the CLI can fail with an NPE in
[
https://issues.apache.org/jira/browse/KAFKA-10191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148556#comment-17148556
]
Chia-Ping Tsai commented on KAFKA-10191:
{quote}
about adding KafkaStreams#cleanUp() in the
[
https://issues.apache.org/jira/browse/KAFKA-10220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148550#comment-17148550
]
huxihx commented on KAFKA-10220:
[~ecomar] Thanks for reporting. I could not reproduce this issue with
rajinisivaram merged pull request #8683:
URL: https://github.com/apache/kafka/pull/8683
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
rajinisivaram commented on pull request #8683:
URL: https://github.com/apache/kafka/pull/8683#issuecomment-651726976
Streams test failures not related, merging to trunk.
This is an automated message from the Apache Git
omkreddy commented on pull request #8885:
URL: https://github.com/apache/kafka/pull/8885#issuecomment-651724728
retest this please
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/KAFKA-10220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Edoardo Comar updated KAFKA-10220:
--
Comment: was deleted
(was: deserialized request data has a null configurationKeys
[
https://issues.apache.org/jira/browse/KAFKA-10220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148535#comment-17148535
]
Edoardo Comar commented on KAFKA-10220:
---
deserialized request data has a null configurationKeys
[
https://issues.apache.org/jira/browse/KAFKA-10220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Edoardo Comar updated KAFKA-10220:
--
Description:
In current trunk code
Describing a topic from the CLI can fail with an NPE in
[
https://issues.apache.org/jira/browse/KAFKA-10221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-10221:
--
Fix Version/s: 2.5.1
> Backport fix for KAFKA-9603 to 2.5
>
Bruno Cadonna created KAFKA-10221:
-
Summary: Backport fix for KAFKA-9603 to 2.5
Key: KAFKA-10221
URL: https://issues.apache.org/jira/browse/KAFKA-10221
Project: Kafka
Issue Type: Bug
Edoardo Comar created KAFKA-10220:
-
Summary: NPE when describing resources
Key: KAFKA-10220
URL: https://issues.apache.org/jira/browse/KAFKA-10220
Project: Kafka
Issue Type: Bug
jeqo opened a new pull request #8956:
URL: https://github.com/apache/kafka/pull/8956
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
cadonna commented on pull request #8914:
URL: https://github.com/apache/kafka/pull/8914#issuecomment-651699622
The failed system test does not seem to be related to this PR but rather to
https://issues.apache.org/jira/browse/KAFKA-10191.
cadonna commented on a change in pull request #8902:
URL: https://github.com/apache/kafka/pull/8902#discussion_r447567460
##
File path:
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStoreTest.java
##
@@ -124,18 +141,19 @@ public void before() {
LMnet commented on pull request #8955:
URL: https://github.com/apache/kafka/pull/8955#issuecomment-651694260
@vvcephei @mjsax
This is an automated message from the Apache Git Service.
To respond to the message, please log on
LMnet commented on pull request #8049:
URL: https://github.com/apache/kafka/pull/8049#issuecomment-651690176
Closed in favor of a https://github.com/apache/kafka/pull/8955
This is an automated message from the Apache Git
LMnet commented on a change in pull request #8049:
URL: https://github.com/apache/kafka/pull/8049#discussion_r447559838
##
File path:
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/Serdes.scala
##
@@ -30,12 +32,15 @@ object Serdes {
implicit def
LMnet closed pull request #8049:
URL: https://github.com/apache/kafka/pull/8049
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
LMnet opened a new pull request #8955:
URL: https://github.com/apache/kafka/pull/8955
Implementation of a solution for KIP-616.
Wildcard import of the old `org.apache.kafka.streams.scala.Serdes` leads
to a name clash because some of implicits has the same names as types
from
akatona84 commented on pull request #8859:
URL: https://github.com/apache/kafka/pull/8859#issuecomment-651684469
I did not find anything for that version, thanks again.
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/KAFKA-10191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148475#comment-17148475
]
mohamed chebbi commented on KAFKA-10191:
[~chia7712] sorry to be late, i read the reset tool
dajac opened a new pull request #8954:
URL: https://github.com/apache/kafka/pull/8954
This PR refactors the various quota integration tests in the `kafka.api`
package and migrates them to using the new quota API instead of writing the
quota to ZK directly.
### Committer Checklist
mimaison commented on pull request #8921:
URL: https://github.com/apache/kafka/pull/8921#issuecomment-651658489
@satishbellapu I'll try to take a look Thursday or Friday
This is an automated message from the Apache Git
mimaison commented on pull request #8295:
URL: https://github.com/apache/kafka/pull/8295#issuecomment-651657082
The conflicts are pretty nasty. I started looking at it last week but did
not have the time (nor the courage!) to finish. I plan to take another look
this week
1 - 100 of 109 matches
Mail list logo
