[
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
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-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
[
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:all-tabpanel
]
RivenSun updated KAFKA-13576:
-
Description:
h1. Problem:
After all client machines are switched to the company's private BYOIP,
produ
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
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
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,
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
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
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...
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
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(
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
[
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
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
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 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(
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
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
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.
//
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_r779162870
##
File path: core/src/main/scala/kafka/log/remote/RemoteIndexCache.scala
##
@@ -0,0 +1,225 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) un
[
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
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
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
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 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 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
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,
}
/**
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..
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
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
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
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 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
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
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
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
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...
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
[
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
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
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.
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
[
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 #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
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.
49 matches
Mail list logo
