bertdewolf commented on pull request #6305:
URL: https://github.com/apache/kafka/pull/6305#issuecomment-691908682
Is this available in any release? I can't seem to find it...
This is an automated message from the Apache Git S
[
https://issues.apache.org/jira/browse/KAFKA-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divya Guduru reassigned KAFKA-10475:
Assignee: Divya Guduru
> Using same key reports different count of records for groupBy()
showuon commented on pull request #9261:
URL: https://github.com/apache/kafka/pull/9261#issuecomment-691930537
@mimaison @vvcephei , could you help review this small PR? Thanks.
This is an automated message from the Apache G
[
https://issues.apache.org/jira/browse/KAFKA-7575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17195359#comment-17195359
]
Megha Shesha commented on KAFKA-7575:
-
Hi, is there a workaround for this issue? I ju
showuon commented on pull request #9121:
URL: https://github.com/apache/kafka/pull/9121#issuecomment-691990481
@mjsax could you review this PR again? Thanks.
This is an automated message from the Apache Git Service.
To respo
chia7712 opened a new pull request #9283:
URL: https://github.com/apache/kafka/pull/9283
Both of ```ControlPlaneNetworkProcessorAvgIdlePercent``` and
```ControlPlaneExpiredConnectionsKilledCount```are exposed with meaningless
value when ```control.plane.listener.name``` is unset. They shou
[
https://issues.apache.org/jira/browse/KAFKA-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-9697:
-
Assignee: Chia-Ping Tsai
> ControlPlaneNetworkProcessorAvgIdlePercent is always NaN
> --
cadonna commented on a change in pull request #8892:
URL: https://github.com/apache/kafka/pull/8892#discussion_r487867246
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsAssignmentScaleTest.java
##
@@ -0,0 +1,224 @@
+/*
+ * Licensed to t
[
https://issues.apache.org/jira/browse/KAFKA-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna reassigned KAFKA-10292:
-
Assignee: Bruno Cadonna
> fix flaky streams/streams_broker_bounce_test.py
> ---
rajinisivaram commented on a change in pull request #9272:
URL: https://github.com/apache/kafka/pull/9272#discussion_r487909815
##
File path: clients/src/main/java/org/apache/kafka/common/metrics/Sensor.java
##
@@ -53,12 +54,20 @@
private final Object metricLock;
pr
Chia-Ping Tsai created KAFKA-10479:
--
Summary: Throw exception if users try to update configs of
existing listeners
Key: KAFKA-10479
URL: https://issues.apache.org/jira/browse/KAFKA-10479
Project: Kaf
[
https://issues.apache.org/jira/browse/KAFKA-10479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-10479:
---
Summary: Throw exception if users try to update configs of existent
listeners (was: Throw e
chia7712 opened a new pull request #9284:
URL: https://github.com/apache/kafka/pull/9284
```scala
def immutableListenerConfigs(kafkaConfig: KafkaConfig, prefix: String):
Map[String, AnyRef] = {
newConfig.originals.asScala.filter { case (key, _) =>
key.startsWith(prefi
mumrah commented on pull request #9246:
URL: https://github.com/apache/kafka/pull/9246#issuecomment-692093776
Closing this since ASF's Jenkins will strip off any CSS for HTML reports
which seriously limits the usefulness of viewing these reports. Will move
streams quickstart fix to a separ
mumrah closed pull request #9246:
URL: https://github.com/apache/kafka/pull/9246
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
mumrah opened a new pull request #9285:
URL: https://github.com/apache/kafka/pull/9285
Running commands like "cd" or setting variables inside `sh` steps do not
survive to following steps in Jenkinsfile. Instead we're supposed to use things
like `dir("somedir") { ... }` and injecting variab
vvcephei commented on a change in pull request #9273:
URL: https://github.com/apache/kafka/pull/9273#discussion_r487982961
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
##
@@ -242,7 +242,8 @@ public ByteBuffer su
vvcephei commented on a change in pull request #9273:
URL: https://github.com/apache/kafka/pull/9273#discussion_r487986285
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
##
@@ -242,7 +242,8 @@ public ByteBuffer su
vvcephei commented on a change in pull request #9273:
URL: https://github.com/apache/kafka/pull/9273#discussion_r487988227
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignmentInfo.java
##
@@ -186,6 +186,15 @@ public ByteBuffer
dajac commented on pull request #9272:
URL: https://github.com/apache/kafka/pull/9272#issuecomment-692106724
@apovzner @rajinisivaram Thanks for your feedback. I have addressed your
comments.
This is an automated message fro
ijuma commented on pull request #9282:
URL: https://github.com/apache/kafka/pull/9282#issuecomment-692106701
Test failures are unrelated:
> Build / JDK 15 /
org.apache.kafka.connect.mirror.MirrorConnectorsIntegrationTest.testReplication
> Build / JDK 15 /
kafka.network.DynamicCon
ijuma merged pull request #9282:
URL: https://github.com/apache/kafka/pull/9282
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
Abuli Palagashvili created KAFKA-10480:
--
Summary: Kafka streams application is being stuck
Key: KAFKA-10480
URL: https://issues.apache.org/jira/browse/KAFKA-10480
Project: Kafka
Issue Ty
[
https://issues.apache.org/jira/browse/KAFKA-10162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot reassigned KAFKA-10162:
---
Assignee: David Jacot
> Use Token Bucket algorithm for controller mutation quota
>
[
https://issues.apache.org/jira/browse/KAFKA-10162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-10162.
-
Resolution: Fixed
> Use Token Bucket algorithm for controller mutation quota
> -
[
https://issues.apache.org/jira/browse/KAFKA-10480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Abuli Palagashvili updated KAFKA-10480:
---
Priority: Blocker (was: Major)
> Kafka streams application is being stuck
> ---
vvcephei merged pull request #9261:
URL: https://github.com/apache/kafka/pull/9261
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 t
junrao merged pull request #9178:
URL: https://github.com/apache/kafka/pull/9178
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
rajinisivaram commented on a change in pull request #9275:
URL: https://github.com/apache/kafka/pull/9275#discussion_r487974401
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java
##
@@ -232,19 +263,25 @@ public FetchRequest build(short versi
ableegoldman commented on pull request #8892:
URL: https://github.com/apache/kafka/pull/8892#issuecomment-692166978
Whoops, I forgot to undo the reversion of #9231 before pushing. It was
giving me trouble compiling in my IDE so I just reverted it to unblock my
testing for the time being
[
https://issues.apache.org/jira/browse/KAFKA-10477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shaik Zakir Hussain reassigned KAFKA-10477:
---
Assignee: Shaik Zakir Hussain
> Sink Connector fails with DataException whe
mimaison commented on pull request #8295:
URL: https://github.com/apache/kafka/pull/8295#issuecomment-692191592
@abbccdda Gentle reminder =)
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/KAFKA-10434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reassigned KAFKA-10434:
Assignee: Jorge Esteban Quilcate Otoya
> Remove deprecated methods on WindowStore
> -
[
https://issues.apache.org/jira/browse/KAFKA-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10455:
-
Fix Version/s: 2.6.1
2.7.0
> Probing rebalances are not guaranteed to be trig
[
https://issues.apache.org/jira/browse/KAFKA-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10455:
-
Priority: Blocker (was: Major)
> Probing rebalances are not guaranteed to be triggered by non-l
MicahRam commented on pull request #8181:
URL: https://github.com/apache/kafka/pull/8181#issuecomment-692230839
oh @mjsax as far as the workaround we call `remove` before `add`, that
solved the memory issue and for the most part solved the
ConcurrentModificationException since less time is
rajinisivaram commented on pull request #9272:
URL: https://github.com/apache/kafka/pull/9272#issuecomment-692242238
@dajac Thanks for the update, test failures not related, merging to trunk.
This is an automated message from
rajinisivaram merged pull request #9272:
URL: https://github.com/apache/kafka/pull/9272
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
rondagostino commented on pull request #9274:
URL: https://github.com/apache/kafka/pull/9274#issuecomment-692271106
@cmccabe There were several test failures at first, so I pushed commit
https://github.com/apache/kafka/pull/9274/commits/fb417ade01613dad8fa2574c4ea3484f3fa4e65f
to fix them
cadonna opened a new pull request #9286:
URL: https://github.com/apache/kafka/pull/9286
The test StreamsBrokerBounceTest.test_all_brokers_bounce() fails on
2.5 because in the last stage of the test there is only one broker
left and the offset commit cannot succeed because the
min.in
cadonna commented on pull request #9286:
URL: https://github.com/apache/kafka/pull/9286#issuecomment-692287164
Call for review: @vvcephei @guozhangwang
This is an automated message from the Apache Git Service.
To respond to
wcarlson5 commented on a change in pull request #9273:
URL: https://github.com/apache/kafka/pull/9273#discussion_r488194586
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -931,6 +932,22 @@ public synchronized boolean close(final long timeou
Bruno Cadonna created KAFKA-10481:
-
Summary: Consider Improving the Success Criteria of Streams'
System Test StreamsBrokerBounceTest
Key: KAFKA-10481
URL: https://issues.apache.org/jira/browse/KAFKA-10481
wcarlson5 commented on a change in pull request #9262:
URL: https://github.com/apache/kafka/pull/9262#discussion_r488215737
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
##
@@ -328,15 +328,15 @@ private synchronized void c
ableegoldman commented on a change in pull request #8892:
URL: https://github.com/apache/kafka/pull/8892#discussion_r488236067
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsAssignmentScaleTest.java
##
@@ -0,0 +1,224 @@
+/*
+ * Licensed
ijuma merged pull request #9257:
URL: https://github.com/apache/kafka/pull/9257
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
hachikuji commented on a change in pull request #9275:
URL: https://github.com/apache/kafka/pull/9275#discussion_r488262695
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java
##
@@ -232,19 +263,25 @@ public FetchRequest build(short version)
[
https://issues.apache.org/jira/browse/KAFKA-10447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma resolved KAFKA-10447.
-
Fix Version/s: 2.7.0
Resolution: Fixed
> Migrate tools module to JUnit 5
> --
ableegoldman commented on a change in pull request #8892:
URL: https://github.com/apache/kafka/pull/8892#discussion_r488267594
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsAssignmentScaleTest.java
##
@@ -0,0 +1,224 @@
+/*
+ * Licensed
hachikuji commented on a change in pull request #9275:
URL: https://github.com/apache/kafka/pull/9275#discussion_r488271329
##
File path: core/src/test/scala/unit/kafka/server/FetchRequestTest.scala
##
@@ -212,6 +212,44 @@ class FetchRequestTest extends BaseRequestTest {
a
ableegoldman commented on pull request #8892:
URL: https://github.com/apache/kafka/pull/8892#issuecomment-692350073
Alright I decided to un-parametrize the tests so we could run the different
task assignors with different inputs instead of relaxing the tests to allow for
the slowest assign
cmccabe commented on a change in pull request #9279:
URL: https://github.com/apache/kafka/pull/9279#discussion_r488276782
##
File path:
generator/src/main/java/org/apache/kafka/message/JsonConverterGenerator.java
##
@@ -53,17 +53,17 @@ public void generateAndWrite(MessageSpec
cmccabe commented on pull request #9274:
URL: https://github.com/apache/kafka/pull/9274#issuecomment-692361175
LGTM. Thanks, @rondagostino
This is an automated message from the Apache Git Service.
To respond to the message,
cmccabe merged pull request #9274:
URL: https://github.com/apache/kafka/pull/9274
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 th
mumrah commented on pull request #9285:
URL: https://github.com/apache/kafka/pull/9285#issuecomment-692387059
Here's the evidence that it's working now
https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-9285/1/execution/node/134/log/
:)
--
mumrah edited a comment on pull request #9285:
URL: https://github.com/apache/kafka/pull/9285#issuecomment-692387059
Here's the evidence that it's working now
https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-9285/1/execution/node/134/log/
@hachikuji @rajinisivaram Could you take a look?
This issue was introduced by
https://github.com/apache/kafk
cnZach commented on pull request #9236:
URL: https://github.com/apache/kafka/pull/9236#issuecomment-692409942
> @cnZach can you rebase this PR against trunk? That will trigger the build.
Hi @omkreddy , do I need to change anything for this PR?
---
guozhangwang commented on a change in pull request #8988:
URL: https://github.com/apache/kafka/pull/8988#discussion_r488375084
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupOffsetsResult.java
##
@@ -34,7 +34,7 @@
final KafkaFuture>
ning2008wisc opened a new pull request #9287:
URL: https://github.com/apache/kafka/pull/9287
The idea is to centralize the common functions of current
`MirrorSourceConnector` and `MirrorSourceTask` to prepare for reusing them in
new Sink Connector and Sink Task.
Two new files are pr
Luke Chen created KAFKA-10482:
-
Summary: Fix flaky testDynamicListenerConnectionCreationRateQuota
Key: KAFKA-10482
URL: https://issues.apache.org/jira/browse/KAFKA-10482
Project: Kafka
Issue Type
showuon commented on pull request #9202:
URL: https://github.com/apache/kafka/pull/9202#issuecomment-692508123
@ijuma , could you check this PR again? Thanks.
This is an automated message from the Apache Git Service.
To respo
showuon opened a new pull request #9288:
URL: https://github.com/apache/kafka/pull/9288
Increase the connection close waiting time to make the test more reliable.
It waits for 15 secs for now, which causes the test failed frequently. Increase
the waiting time to 25 secs.
### Commit
65 matches
Mail list logo
