showuon closed pull request #11578:
URL: https://github.com/apache/kafka/pull/11578
--
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: jira-unsubscr.
showuon commented on pull request #11578:
URL: https://github.com/apache/kafka/pull/11578#issuecomment-1006341423
@ableegoldman , yes, you're right. I didn't check the logs clearly. It looks
like there's a bug in general assignor that assign the same partition to
multiple consumers. I'll s
[
https://issues.apache.org/jira/browse/KAFKA-13514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17469743#comment-17469743
]
Luke Chen commented on KAFKA-13514:
---
[~ableegoldman] [~mjsax] , It looks like the assi
showuon commented on pull request #11613:
URL: https://github.com/apache/kafka/pull/11613#issuecomment-1006329948
@mjsax , please take a look when available. Thank you.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
cmccabe merged pull request #11637:
URL: https://github.com/apache/kafka/pull/11637
--
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: jira-unsubscr.
cmccabe commented on pull request #11637:
URL: https://github.com/apache/kafka/pull/11637#issuecomment-1006304214
Failed tests are
`org.apache.kafka.streams.integration.StoreQueryIntegrationTest` and
kafka.admin.LeaderElectionCommandTest`, which are not related.
--
This is an automated
[
https://issues.apache.org/jira/browse/KAFKA-13476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-13476.
-
Fix Version/s: 3.2.0
Resolution: Fixed
> Streams crashes when non Base64 Offset M
mjsax commented on pull request #11535:
URL: https://github.com/apache/kafka/pull/11535#issuecomment-1006299533
Thanks for the PR! Merged to `trunk`.
--
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
mjsax merged pull request #11535:
URL: https://github.com/apache/kafka/pull/11535
--
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: jira-unsubscr...
vvcephei merged pull request #11650:
URL: https://github.com/apache/kafka/pull/11650
--
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: jira-unsubscr
dongjinleekr commented on pull request #7898:
URL: https://github.com/apache/kafka/pull/7898#issuecomment-1006282789
@gabrieljones
> How hard is it to backport this all the way back to Kafka v2.3.x?
Almost impossible. There are too many conflicts.
--
This is an automated mes
showuon commented on pull request #11340:
URL: https://github.com/apache/kafka/pull/11340#issuecomment-1006251125
The failed tests are flaky and also failed sometimes in recent trunk jenkins
build. Looks good.
```
Build / ARM / kafka.server.ReplicaManagerTest.[1] usesTopicIds=true
vvcephei merged pull request #11624:
URL: https://github.com/apache/kafka/pull/11624
--
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: jira-unsubscr
vvcephei commented on pull request #11624:
URL: https://github.com/apache/kafka/pull/11624#issuecomment-1006246786
Unrelated test failure:
```
Build / JDK 17 and Scala 2.13 /
testTopicIdUpgradeAfterReassigningPartitions() –
kafka.controller.ControllerIntegrationTest
```
--
This
vvcephei commented on pull request #11652:
URL: https://github.com/apache/kafka/pull/11652#issuecomment-1006244975
Unrelated test failures:
```
Build / ARM / kafka.server.ReplicaManagerTest.[1] usesTopicIds=true
Build / JDK 8 and Scala 2.12 /
kafka.api.ConsumerBounceTest.testCloseD
dengziming commented on pull request #11629:
URL: https://github.com/apache/kafka/pull/11629#issuecomment-1006228274
> Hmm, I'm not sure I follow. What makes you think the metadata change is
not getting propagated?
The QA Test failure is related to this PR, and I run this test locall
cmccabe commented on a change in pull request #11629:
URL: https://github.com/apache/kafka/pull/11629#discussion_r779255324
##
File path:
core/src/test/scala/integration/kafka/api/IntegrationTestHarness.scala
##
@@ -80,6 +81,19 @@ abstract class IntegrationTestHarness extends
junrao merged pull request #11641:
URL: https://github.com/apache/kafka/pull/11641
--
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: jira-unsubscr..
junrao commented on a change in pull request #11390:
URL: https://github.com/apache/kafka/pull/11390#discussion_r779191474
##
File path: core/src/main/scala/kafka/server/ReplicaFetcherThread.scala
##
@@ -386,11 +397,109 @@ class ReplicaFetcherThread(name: String,
}
/**
cmccabe commented on pull request #11629:
URL: https://github.com/apache/kafka/pull/11629#issuecomment-1006197493
> It seems that metadata change is not propagated to KRaftMetadataCache
timely, we shoud add an assertion before sending metadata request in
AbstractCreateTopicsRequestTest.val
cmccabe commented on a change in pull request #11629:
URL: https://github.com/apache/kafka/pull/11629#discussion_r779227016
##
File path:
core/src/test/scala/integration/kafka/api/IntegrationTestHarness.scala
##
@@ -80,6 +81,19 @@ abstract class IntegrationTestHarness extends
cmccabe commented on a change in pull request #11629:
URL: https://github.com/apache/kafka/pull/11629#discussion_r779226683
##
File path: core/src/test/scala/unit/kafka/server/CreateTopicsRequestTest.scala
##
@@ -99,29 +101,33 @@ class CreateTopicsRequestTest extends
AbstractC
cmccabe commented on pull request #11637:
URL: https://github.com/apache/kafka/pull/11637#issuecomment-1006185759
Oops, the quorum parameter should be present for all of these. Fixed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
hachikuji commented on a change in pull request #11629:
URL: https://github.com/apache/kafka/pull/11629#discussion_r779218571
##
File path:
core/src/test/scala/integration/kafka/api/IntegrationTestHarness.scala
##
@@ -80,6 +81,19 @@ abstract class IntegrationTestHarness extend
[
https://issues.apache.org/jira/browse/KAFKA-13435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17469592#comment-17469592
]
Jason Gustafson commented on KAFKA-13435:
-
[~dajac] [~rleslie] [~guozhang] Thank
ccding commented on a change in pull request #11390:
URL: https://github.com/apache/kafka/pull/11390#discussion_r779162870
##
File path: core/src/main/scala/kafka/log/remote/RemoteIndexCache.scala
##
@@ -0,0 +1,225 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) un
ccding commented on a change in pull request #11390:
URL: https://github.com/apache/kafka/pull/11390#discussion_r778990618
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/ListOffsetsRequest.java
##
@@ -42,6 +42,11 @@
public static final long LATEST_TI
ccding commented on a change in pull request #11390:
URL: https://github.com/apache/kafka/pull/11390#discussion_r778999529
##
File path: clients/src/main/resources/common/message/ListOffsetsResponse.json
##
@@ -31,7 +31,10 @@
// Version 6 enables flexible versions.
//
vvcephei commented on a change in pull request #11650:
URL: https://github.com/apache/kafka/pull/11650#discussion_r779188902
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/IQv2StoreIntegrationTest.java
##
@@ -626,6 +627,118 @@ public void process(fina
lbradstreet opened a new pull request #11653:
URL: https://github.com/apache/kafka/pull/11653
We essentially end up waiting far too long to shutdown the purgatory and
quota manager ShutdownableThreads.
--
This is an automated message from the Apache Git Service.
To respond to the message
guozhangwang commented on a change in pull request #11650:
URL: https://github.com/apache/kafka/pull/11650#discussion_r779180990
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/IQv2StoreIntegrationTest.java
##
@@ -626,6 +627,118 @@ public void process(
guozhangwang commented on pull request #11652:
URL: https://github.com/apache/kafka/pull/11652#issuecomment-1006129355
Suspect there are some race conditions in `KafkaStreams#close` that would
leak threads.
--
This is an automated message from the Apache Git Service.
To respond to the me
guozhangwang opened a new pull request #11652:
URL: https://github.com/apache/kafka/pull/11652
1. Add num of threads logging upon shutdown.
2. Prefix the shutdown thread with client id.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
[
https://issues.apache.org/jira/browse/KAFKA-12537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17469566#comment-17469566
]
Guozhang Wang commented on KAFKA-12537:
---
Hey [~wcarlson5] just for my own understa
lbradstreet opened a new pull request #11651:
URL: https://github.com/apache/kafka/pull/11651
This will need some better jenkins reporting in order to be mergeable.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
vvcephei commented on a change in pull request #11650:
URL: https://github.com/apache/kafka/pull/11650#discussion_r779160412
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/IQv2StoreIntegrationTest.java
##
@@ -800,13 +914,13 @@ public void verifyStore(
vvcephei opened a new pull request #11650:
URL: https://github.com/apache/kafka/pull/11650
During some recent reviews, @mjsax pointed out that StateStore layers
are constructed differently the stores are added via the PAPI vs. the DSL.
This PR adds PAPI construction for Window and
mjsax merged pull request #11648:
URL: https://github.com/apache/kafka/pull/11648
--
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: jira-unsubscr...
gabrieljones edited a comment on pull request #7898:
URL: https://github.com/apache/kafka/pull/7898#issuecomment-1005938463
How hard is it to backport this all the way back to Kafka v2.3.x?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
gabrieljones commented on pull request #7898:
URL: https://github.com/apache/kafka/pull/7898#issuecomment-1005938463
How hard would it be to backport this all the way back to kafka 2.3.x?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
junrao commented on a change in pull request #11641:
URL: https://github.com/apache/kafka/pull/11641#discussion_r778987140
##
File path: clients/src/main/java/org/apache/kafka/common/utils/Utils.java
##
@@ -924,7 +924,7 @@ public static void atomicMoveWithFallback(Path source,
vamossagar12 commented on pull request #11424:
URL: https://github.com/apache/kafka/pull/11424#issuecomment-1005895064
hey @guozhangwang , For `CACHE_MAX_BYTES_BUFFERING_CONFIG` , I can replace
but as per one of the comments here =>
https://github.com/apache/kafka/pull/11424#discussion_r7
mimaison commented on pull request #11560:
URL: https://github.com/apache/kafka/pull/11560#issuecomment-1005536732
@dajac @rajinisivaram Do you also want to take a look? If not, I'll merge
later this week. Thanks
--
This is an automated message from the Apache Git Service.
To respond to
[
https://issues.apache.org/jira/browse/KAFKA-13576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RivenSun updated KAFKA-13576:
-
Description:
h1. Problem:
After all client machines are switched to the company's private BYOIP,
produ
[
https://issues.apache.org/jira/browse/KAFKA-13570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17469134#comment-17469134
]
Fredrik Arvidsson commented on KAFKA-13570:
---
Would have been nice having such
[
https://issues.apache.org/jira/browse/KAFKA-13576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17469124#comment-17469124
]
RivenSun commented on KAFKA-13576:
--
Hi [~showuon] [~guozhang]
Please help check this
RivenSun created KAFKA-13576:
Summary: Processor.ConnectionQueueSize provides configuration &
metrics, SelectorMetrics adds connection-register related metrics
Key: KAFKA-13576
URL: https://issues.apache.org/jira/brow
[
https://issues.apache.org/jira/browse/KAFKA-13575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17469101#comment-17469101
]
Alok Kumar Singh edited comment on KAFKA-13575 at 1/5/22, 8:08 AM:
---
[
https://issues.apache.org/jira/browse/KAFKA-13575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17469101#comment-17469101
]
Alok Kumar Singh commented on KAFKA-13575:
--
If someone picks this we have a run
49 matches
Mail list logo
