jonathansantilli commented on pull request #7877:
URL: https://github.com/apache/kafka/pull/7877#issuecomment-695958093
Hi there @d8tltanc sorry about the delay with my reply.
I would like to continue working on this PR. There was some consensus at the
beginning about a possible solu
[
https://issues.apache.org/jira/browse/KAFKA-10496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Rżysko reassigned KAFKA-10496:
Assignee: Piotr Rżysko
> Create an in-memory DNS server for ClientUtilsTest and
> Cluste
[
https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199235#comment-17199235
]
Michael Silbermann commented on KAFKA-8803:
---
[~guozhang] thanks, we will try to
cadonna commented on a change in pull request #9262:
URL: https://github.com/apache/kafka/pull/9262#discussion_r491864886
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
##
@@ -306,59 +305,69 @@ public synchronized void clea
[
https://issues.apache.org/jira/browse/KAFKA-10505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nikolay Izhikov reassigned KAFKA-10505:
---
Assignee: Nikolay Izhikov
> [SystemTests] streams_static_membership.py and streams_
Nikolay Izhikov created KAFKA-10505:
---
Summary: [SystemTests] streams_static_membership.py and
streams_upgradet_test.py fails
Key: KAFKA-10505
URL: https://issues.apache.org/jira/browse/KAFKA-10505
P
nizhikov opened a new pull request #9312:
URL: https://github.com/apache/kafka/pull/9312
Two tests fails with the same reason:
```
File
"/opt/kafka-dev/tests/kafkatest/tests/streams/streams_upgrade_test.py", line
533, in extract_highest_generation
return int(found_generation
cadonna commented on a change in pull request #9262:
URL: https://github.com/apache/kafka/pull/9262#discussion_r491866714
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
##
@@ -306,59 +305,69 @@ public synchronized void clea
cadonna commented on a change in pull request #9262:
URL: https://github.com/apache/kafka/pull/9262#discussion_r491880515
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
##
@@ -306,59 +305,69 @@ public synchronized void clea
nizhikov commented on pull request #9312:
URL: https://github.com/apache/kafka/pull/9312#issuecomment-695991209
Hello, @mjsax @ableegoldman
2 system tests for streams are fails because of an unexpected string format.
I fixed it.
Please, take a look at my PR.
-
cadonna commented on a change in pull request #9262:
URL: https://github.com/apache/kafka/pull/9262#discussion_r49183
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
##
@@ -306,59 +305,69 @@ public synchronized void clea
nizhikov commented on pull request #9196:
URL: https://github.com/apache/kafka/pull/9196#issuecomment-695992855
Hello, @guozhangwang
2 tests that fails in this branch fails in the trunk too.
I fixed them in #9312
Please, take a look.
```
File
"/opt/kafka-dev/t
[
https://issues.apache.org/jira/browse/KAFKA-10482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199280#comment-17199280
]
Luke Chen commented on KAFKA-10482:
---
[https://ci-builds.apache.org/blue/rest/organizat
showuon commented on a change in pull request #9202:
URL: https://github.com/apache/kafka/pull/9202#discussion_r491908542
##
File path:
core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala
##
@@ -1402,23 +1403,18 @@ object GroupMetadataManager {
val va
showuon commented on a change in pull request #9202:
URL: https://github.com/apache/kafka/pull/9202#discussion_r491908542
##
File path:
core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala
##
@@ -1402,23 +1403,18 @@ object GroupMetadataManager {
val va
showuon commented on a change in pull request #9202:
URL: https://github.com/apache/kafka/pull/9202#discussion_r491908542
##
File path:
core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala
##
@@ -1402,23 +1403,18 @@ object GroupMetadataManager {
val va
showuon commented on a change in pull request #9202:
URL: https://github.com/apache/kafka/pull/9202#discussion_r491908542
##
File path:
core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala
##
@@ -1402,23 +1403,18 @@ object GroupMetadataManager {
val va
showuon commented on a change in pull request #9149:
URL: https://github.com/apache/kafka/pull/9149#discussion_r491912872
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java
##
@@ -363,6 +363,7 @@ private boolean sendRecords() {
Lobashin Denis created KAFKA-10506:
--
Summary: Ssl connectors and tasks have incorrect statuses
Key: KAFKA-10506
URL: https://issues.apache.org/jira/browse/KAFKA-10506
Project: Kafka
Issue Ty
showuon commented on a change in pull request #9149:
URL: https://github.com/apache/kafka/pull/9149#discussion_r491916604
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java
##
@@ -409,6 +410,9 @@ private boolean sendRecords() {
showuon commented on a change in pull request #9149:
URL: https://github.com/apache/kafka/pull/9149#discussion_r491916604
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java
##
@@ -409,6 +410,9 @@ private boolean sendRecords() {
chia7712 commented on pull request #9284:
URL: https://github.com/apache/kafka/pull/9284#issuecomment-696082528
```
Build / JDK 11 /
kafka.api.ConsumerBounceTest.testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup
```
only jdk 11 get failed test. It is unrela
chia7712 commented on pull request #9223:
URL: https://github.com/apache/kafka/pull/9223#issuecomment-696083029
```
Build / JDK 8 /
org.apache.kafka.streams.integration.EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta[true]
```
only jdk 8 gets failure. This flak
chia7712 commented on pull request #9102:
URL: https://github.com/apache/kafka/pull/9102#issuecomment-696083619
@abbccdda ping~
This is an automated message from the Apache Git Service.
To respond to the message, please log o
viktorsomogyi commented on pull request #4090:
URL: https://github.com/apache/kafka/pull/4090#issuecomment-696097321
@ijuma can we get this merged please or do you have any more comments?
This is an automated message from the
chia7712 commented on a change in pull request #9299:
URL: https://github.com/apache/kafka/pull/9299#discussion_r492025863
##
File path: core/src/main/scala/kafka/admin/ZkSecurityMigrator.scala
##
@@ -128,7 +129,7 @@ object ZkSecurityMigrator extends Logging {
// Now overr
shaikzakiriitm commented on pull request #9306:
URL: https://github.com/apache/kafka/pull/9306#issuecomment-696107218
Failures are in ConnectionQuotasTest, and ConsumerBounceTest test classes,
and appear unrelated to the change in this PR.
[
https://issues.apache.org/jira/browse/KAFKA-10484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199387#comment-17199387
]
Bruno Cadonna commented on KAFKA-10484:
---
I think, we should first try to find a go
viktorsomogyi commented on a change in pull request #9281:
URL: https://github.com/apache/kafka/pull/9281#discussion_r492058687
##
File path: core/src/main/scala/kafka/server/KafkaConfig.scala
##
@@ -1686,9 +1686,9 @@ class KafkaConfig(val props: java.util.Map[_, _], doLog:
Bo
[
https://issues.apache.org/jira/browse/KAFKA-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199403#comment-17199403
]
ASF GitHub Bot commented on KAFKA-8360:
---
viktorsomogyi commented on pull request #2
[
https://issues.apache.org/jira/browse/KAFKA-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199404#comment-17199404
]
ASF GitHub Bot commented on KAFKA-8360:
---
viktorsomogyi edited a comment on pull req
[
https://issues.apache.org/jira/browse/KAFKA-8266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199409#comment-17199409
]
Bruno Cadonna commented on KAFKA-8266:
--
This test failed for me with:
{code:java}
or
ijuma commented on a change in pull request #9299:
URL: https://github.com/apache/kafka/pull/9299#discussion_r492077814
##
File path: core/src/main/scala/kafka/admin/ZkSecurityMigrator.scala
##
@@ -128,7 +129,7 @@ object ZkSecurityMigrator extends Logging {
// Now override
ijuma commented on pull request #9298:
URL: https://github.com/apache/kafka/pull/9298#issuecomment-696156076
Failures are unrelated since this only changes the Readme.
This is an automated message from the Apache Git Service.
ijuma merged pull request #9298:
URL: https://github.com/apache/kafka/pull/9298
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
ijuma commented on pull request #9266:
URL: https://github.com/apache/kafka/pull/9266#issuecomment-696170285
Build timed out for some reason, started another one.
This is an automated message from the Apache Git Service.
To r
ijuma commented on pull request #9223:
URL: https://github.com/apache/kafka/pull/9223#issuecomment-696171172
Unrelated flaky failures:
> Build / JDK 8 /
org.apache.kafka.streams.integration.EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta[true]
> Build / JD
scanterog opened a new pull request #9313:
URL: https://github.com/apache/kafka/pull/9313
Currently the producer/consumer properties override for the MirrorSourceTask
and OffsetSyncStore do not work. This is due the props stored into
MirrorConnectorConfig have a `target.cluster` or `source
ijuma merged pull request #9223:
URL: https://github.com/apache/kafka/pull/9223
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
[
https://issues.apache.org/jira/browse/KAFKA-10339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199443#comment-17199443
]
Ning Zhang commented on KAFKA-10339:
[~mimaison] When possible, very appreciated if
ijuma commented on a change in pull request #4090:
URL: https://github.com/apache/kafka/pull/4090#discussion_r492132729
##
File path: core/src/test/scala/unit/kafka/utils/JsonTest.scala
##
@@ -40,25 +40,34 @@ class JsonTest {
def testJsonParse(): Unit = {
val jnf = Json
ankit-kumar-25 opened a new pull request #9314:
URL: https://github.com/apache/kafka/pull/9314
What? :: Mentioning "Request Queue Size" under the Monitoring tab.
RequestQueueSize is an important metric to monitor the number of requests in
the queue. As a crowded queue might face issue proc
[
https://issues.apache.org/jira/browse/KAFKA-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199447#comment-17199447
]
ASF GitHub Bot commented on KAFKA-8360:
---
ankit-kumar-25 commented on pull request #
cmccabe commented on pull request #9103:
URL: https://github.com/apache/kafka/pull/9103#issuecomment-696225206
Hi @abbccdda ,
Thanks for the PR! It looks good. I like the idea behind
`ForwardRequestHandler`.
Since this class doesn't have any internal state, I wonder if it wo
[
https://issues.apache.org/jira/browse/KAFKA-10339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199492#comment-17199492
]
Mickael Maison commented on KAFKA-10339:
Thanks [~yangguo1220]. I've seen your r
hachikuji commented on a change in pull request #9202:
URL: https://github.com/apache/kafka/pull/9202#discussion_r492203555
##
File path:
core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala
##
@@ -1402,23 +1403,18 @@ object GroupMetadataManager {
val
[
https://issues.apache.org/jira/browse/KAFKA-10460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199494#comment-17199494
]
Ankit Kumar commented on KAFKA-10460:
-
Hey [~robinp-tw],
Are you working on this? I
hachikuji commented on a change in pull request #9130:
URL: https://github.com/apache/kafka/pull/9130#discussion_r492211755
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -182,10 +182,13 @@ class KafkaApis(val requestChannel: RequestChannel,
case
scanterog commented on pull request #9313:
URL: https://github.com/apache/kafka/pull/9313#issuecomment-696259251
Hello @ryannedolan @mimaison. Your review will be appreciated. I think the
test failure is unrelated. Thanks!
T
[
https://issues.apache.org/jira/browse/KAFKA-10339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199546#comment-17199546
]
Ning Zhang commented on KAFKA-10339:
Thanks [~mimaison], once the above PR 8730 is m
scanterog commented on pull request #9313:
URL: https://github.com/apache/kafka/pull/9313#issuecomment-696271853
Thanks @ryannedolan! what is the usual procedure to get this merged?
This is an automated message from the Apach
ryannedolan commented on pull request #9313:
URL: https://github.com/apache/kafka/pull/9313#issuecomment-696275095
> Thanks @ryannedolan! what is the usual procedure to get this merged?
A committer must approve and merge.
-
abbccdda commented on pull request #9103:
URL: https://github.com/apache/kafka/pull/9103#issuecomment-696281629
@cmccabe Sounds good to me to remove the customized error helper.
This is an automated message from the Apache Gi
piotrrzysko opened a new pull request #9315:
URL: https://github.com/apache/kafka/pull/9315
As ticket suggested I’ve tried to introduce in-memory DNS server for testing
purposes, but unfortunately capability to change default DNS provider has been
removed in Java 9: https://bugs.openjdk.ja
[
https://issues.apache.org/jira/browse/KAFKA-10505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10505:
Component/s: system tests
streams
> [SystemTests] streams_static_membersh
hachikuji commented on pull request #9130:
URL: https://github.com/apache/kafka/pull/9130#issuecomment-696301126
As long as there are no problems with the build, I am planning to merge this
within the next couple days. For a history of the review comments, please see:
https://github.com/co
[
https://issues.apache.org/jira/browse/KAFKA-9075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199589#comment-17199589
]
Matthias J. Sax commented on KAFKA-9075:
[~high.lee] Are you still interested? Se
Jason Gustafson created KAFKA-10507:
---
Summary: Limit the set of APIs returned in pre-authentication
ApiVersions
Key: KAFKA-10507
URL: https://issues.apache.org/jira/browse/KAFKA-10507
Project: Kafk
abbccdda commented on pull request #9270:
URL: https://github.com/apache/kafka/pull/9270#issuecomment-696308421
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please lo
ableegoldman commented on a change in pull request #9083:
URL: https://github.com/apache/kafka/pull/9083#discussion_r492282511
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java
##
@@ -217,12 +217,12 @@ public StateStore
abbccdda commented on pull request #9270:
URL: https://github.com/apache/kafka/pull/9270#issuecomment-696317720
test this
This is an automated message from the Apache Git Service.
To respond to the message, please log on
vvcephei commented on a change in pull request #8892:
URL: https://github.com/apache/kafka/pull/8892#discussion_r492302522
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientState.java
##
@@ -288,17 +288,17 @@ public void computeT
[
https://issues.apache.org/jira/browse/KAFKA-10507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199628#comment-17199628
]
David Jacot commented on KAFKA-10507:
-
That would make sense for the Java client cau
[
https://issues.apache.org/jira/browse/KAFKA-10507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot reassigned KAFKA-10507:
---
Assignee: David Jacot
> Limit the set of APIs returned in pre-authentication ApiVersions
>
[
https://issues.apache.org/jira/browse/KAFKA-10507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199639#comment-17199639
]
Jason Gustafson commented on KAFKA-10507:
-
[~dajac] Good point. If you can confi
vvcephei commented on a change in pull request #8181:
URL: https://github.com/apache/kafka/pull/8181#discussion_r492316319
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -581,8 +580,8 @@ public void punctuate(final Proces
vvcephei opened a new pull request #9316:
URL: https://github.com/apache/kafka/pull/9316
Clarify some confusing variable and method names.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build statu
[
https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199651#comment-17199651
]
John Roesler commented on KAFKA-10493:
--
Hi all,
I took a look, and I think the cod
hachikuji merged pull request #9202:
URL: https://github.com/apache/kafka/pull/9202
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
big-andy-coates commented on pull request #9156:
URL: https://github.com/apache/kafka/pull/9156#issuecomment-696383217
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, pl
mjsax commented on a change in pull request #8181:
URL: https://github.com/apache/kafka/pull/8181#discussion_r492360815
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -581,8 +580,8 @@ public void punctuate(final Processor
ijuma commented on a change in pull request #9299:
URL: https://github.com/apache/kafka/pull/9299#discussion_r492361262
##
File path: core/src/main/scala/kafka/utils/Implicits.scala
##
@@ -46,4 +47,21 @@ object Implicits {
}
+ /**
+ * Exposes `foreachKv` which maps to
[
https://issues.apache.org/jira/browse/KAFKA-10181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10181:
Description: In the bridge release broker,
AlterConfig/IncrementalAlterConfig/CreateTopics/AlterCl
[
https://issues.apache.org/jira/browse/KAFKA-10181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10181:
Summary: Create redirection template for configuration change RPCs (was:
Redirect AlterConfig/Inc
[
https://issues.apache.org/jira/browse/KAFKA-10350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-10350:
---
Assignee: Boyang Chen
> Add redirect request monitoring metrics
> -
Boyang Chen created KAFKA-10508:
---
Summary: Consider moving ForwardRequestHandler to a separate class
Key: KAFKA-10508
URL: https://issues.apache.org/jira/browse/KAFKA-10508
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199688#comment-17199688
]
Guozhang Wang commented on KAFKA-10493:
---
Thanks for double checking John! The PR l
[
https://issues.apache.org/jira/browse/KAFKA-10343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10343:
Summary: Remove 2.7 IBP for redirection enablement (was: Redirect
AlterClientQuotas to the contro
[
https://issues.apache.org/jira/browse/KAFKA-10343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10343:
Description: The shipment of redirection could not be complete in 2.7. With
that being said, we ne
[
https://issues.apache.org/jira/browse/KAFKA-10343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10343:
Fix Version/s: 2.7.0
> Remove 2.7 IBP for redirection enablement
> ---
[
https://issues.apache.org/jira/browse/KAFKA-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199689#comment-17199689
]
Boyang Chen commented on KAFKA-10475:
-
[~saad-rasool] [~guozhang]I don't think we ha
ableegoldman commented on a change in pull request #8892:
URL: https://github.com/apache/kafka/pull/8892#discussion_r492382332
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/AssignmentTestUtils.java
##
@@ -77,13 +86,8 @@
public
ableegoldman commented on a change in pull request #8892:
URL: https://github.com/apache/kafka/pull/8892#discussion_r492383223
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientState.java
##
@@ -288,17 +288,17 @@ public void comp
ijuma merged pull request #9299:
URL: https://github.com/apache/kafka/pull/9299
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
[
https://issues.apache.org/jira/browse/KAFKA-10504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199715#comment-17199715
]
Boyang Chen commented on KAFKA-10504:
-
Is this optimization necessary?
> It will no
abbccdda commented on a change in pull request #9311:
URL: https://github.com/apache/kafka/pull/9311#discussion_r491655717
##
File path:
clients/src/main/java/org/apache/kafka/common/errors/TransactionTimeoutException.java
##
@@ -0,0 +1,43 @@
+/*
+ * Licensed to the Apache Sof
[
https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199724#comment-17199724
]
Matthias J. Sax commented on KAFKA-10493:
-
I have concerns about making it optio
mjsax commented on pull request #9312:
URL: https://github.com/apache/kafka/pull/9312#issuecomment-696464404
@nizhikov @ableegoldman Do we know when this broke? What was the old log
line and what is the new one?
Triggered system test run:
https://jenkins.confluent.io/job/system-test
mjsax commented on a change in pull request #9251:
URL: https://github.com/apache/kafka/pull/9251#discussion_r492434090
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyWindowStore.java
##
@@ -25,6 +25,11 @@
* A window store that only supports read
mjsax commented on pull request #9251:
URL: https://github.com/apache/kafka/pull/9251#issuecomment-696467547
Thanks for the PR @showuon!
This is an automated message from the Apache Git Service.
To respond to the message, ple
mjsax merged pull request #9251:
URL: https://github.com/apache/kafka/pull/9251
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
showuon commented on pull request #9121:
URL: https://github.com/apache/kafka/pull/9121#issuecomment-696467921
@mjsax , sorry, I found you're online now. So could you take a look again
for the long pending PR? It's 2nd review, so it should be easier. Thanks.
-
[
https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199734#comment-17199734
]
John Roesler commented on KAFKA-10493:
--
Thanks, all. I do think it would be nice to
vvcephei commented on a change in pull request #8892:
URL: https://github.com/apache/kafka/pull/8892#discussion_r492436680
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/AssignmentTestUtils.java
##
@@ -77,13 +86,8 @@
public sta
[
https://issues.apache.org/jira/browse/KAFKA-10458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anna Povzner reassigned KAFKA-10458:
Assignee: David Jacot (was: Anna Povzner)
> Need a way to update quota for TokenBucket r
[
https://issues.apache.org/jira/browse/KAFKA-10458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199738#comment-17199738
]
Anna Povzner commented on KAFKA-10458:
--
fixed with [https://github.com/apache/kafka
[
https://issues.apache.org/jira/browse/KAFKA-10458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anna Povzner resolved KAFKA-10458.
--
Resolution: Fixed
> Need a way to update quota for TokenBucket registered with Sensor
> --
Anna Povzner created KAFKA-10509:
Summary: Add metric to track throttle time due to hitting
connection rate quota
Key: KAFKA-10509
URL: https://issues.apache.org/jira/browse/KAFKA-10509
Project: Kafka
ableegoldman commented on a change in pull request #8892:
URL: https://github.com/apache/kafka/pull/8892#discussion_r492447041
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/AssignmentTestUtils.java
##
@@ -77,13 +86,8 @@
public
mjsax commented on a change in pull request #8181:
URL: https://github.com/apache/kafka/pull/8181#discussion_r492360815
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -581,8 +580,8 @@ public void punctuate(final Processor
1 - 100 of 154 matches
Mail list logo
