[
https://issues.apache.org/jira/browse/KAFKA-10482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199878#comment-17199878
]
Luke Chen commented on KAFKA-10482:
---
https://ci-builds.apache.org/blue/rest/organizati
[
https://issues.apache.org/jira/browse/KAFKA-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199858#comment-17199858
]
Saad Rasool commented on KAFKA-10475:
-
[~bchen225242] I will get back to you with sa
chia7712 commented on pull request #9284:
URL: https://github.com/apache/kafka/pull/9284#issuecomment-696528358
> So the previous behavior would have caused the updated configuration to be
persisted, but it wouldn't take effect until the broker was restarted. Is that
right?
You do g
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
abbccdda commented on pull request #9270:
URL: https://github.com/apache/kafka/pull/9270#issuecomment-695909047
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
chia7712 commented on pull request #9162:
URL: https://github.com/apache/kafka/pull/9162#issuecomment-696523232
```
Build / JDK 15 /
org.apache.kafka.streams.integration.EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta[true]
Build / JDK 8 / kafka.api.ConsumerBounceTest
Stanislav Kozlovski created KAFKA-10510:
---
Summary: Reassigning partitions should not allow increasing RF of
a partition unless configured with it
Key: KAFKA-10510
URL: https://issues.apache.org/jira/browse/K
chia7712 commented on pull request #9206:
URL: https://github.com/apache/kafka/pull/9206#issuecomment-696522007
rebase to run JMH again. This patch is still a benefit to validation :)
This is an automated message from the Apa
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
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
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
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
apovzner opened a new pull request #9317:
URL: https://github.com/apache/kafka/pull/9317
This PR adds metric to track throttle time of connection accept rate (when
hitting connection attempt rate quota). This is part of KIP-612:
kafka.network:type=socket-server-metrics,name=connection-a
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
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
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
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.
-
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
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
[
https://issues.apache.org/jira/browse/KAFKA-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199751#comment-17199751
]
ASF GitHub Bot commented on KAFKA-8360:
---
ankit-kumar-25 commented on pull request #
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
huangyiminghappy commented on pull request #9304:
URL: https://github.com/apache/kafka/pull/9304#issuecomment-695813133
@hachikuji would you help to review this pr.
This is an automated message from the Apache Git S
[
https://issues.apache.org/jira/browse/KAFKA-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199774#comment-17199774
]
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=17199758#comment-17199758
]
ASF GitHub Bot commented on KAFKA-8360:
---
viktorsomogyi edited a comment on pull req
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 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() {
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
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
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
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
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
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
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.
-
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
vgvineet4 commented on a change in pull request #9254:
URL: https://github.com/apache/kafka/pull/9254#discussion_r491690401
##
File path: tools/src/main/java/org/apache/kafka/tools/ProducerPerformance.java
##
@@ -132,12 +138,16 @@ public static void main(String[] args) throws E
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.
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
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
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
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.
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
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
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
scanterog commented on pull request #9313:
URL: https://github.com/apache/kafka/pull/9313#issuecomment-696259251
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
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
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.
-
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
guozhangwang commented on a change in pull request #9130:
URL: https://github.com/apache/kafka/pull/9130#discussion_r491745941
##
File path: clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java
##
@@ -415,4 +444,10 @@ public void visit(Type field) {
retu
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
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
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
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
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
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
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
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
[
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
> --
[
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 reassigned KAFKA-10458:
Assignee: David Jacot (was: Anna Povzner)
> Need a way to update quota for TokenBucket r
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-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
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.
-
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
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 #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
[
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
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-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
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
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
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
[
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
[
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-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
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-10350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-10350:
---
Assignee: Boyang Chen
> Add redirect request monitoring metrics
> -
[
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-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
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
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
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
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
[
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
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
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
[
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
[
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=17199628#comment-17199628
]
David Jacot commented on KAFKA-10507:
-
That would make sense for the Java client cau
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
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
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-696308421
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please lo
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
[
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
[
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
1 - 100 of 154 matches
Mail list logo
