showuon commented on a change in pull request #11493:
URL: https://github.com/apache/kafka/pull/11493#discussion_r805556147
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignorTest.java
##
@@ -997,6 +997,77 @@ public void
showuon commented on a change in pull request #11493:
URL: https://github.com/apache/kafka/pull/11493#discussion_r805557480
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignorTest.java
##
@@ -997,6 +997,77 @@ public void
showuon commented on a change in pull request #11493:
URL: https://github.com/apache/kafka/pull/11493#discussion_r805534017
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
##
@@ -784,21 +784,33 @@ private void
guozhangwang commented on a change in pull request #11705:
URL: https://github.com/apache/kafka/pull/11705#discussion_r805466422
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedCogroupedKStreamImpl.java
##
@@ -121,11 +121,20 @@
dengziming edited a comment on pull request #11746:
URL: https://github.com/apache/kafka/pull/11746#issuecomment-1037750296
Hello @dajac @showuon, I found that we set this to a large enough value in
KAFKA-5324 so that we can overwrite per-call timeout with a lager value by
showuon commented on pull request #11616:
URL: https://github.com/apache/kafka/pull/11616#issuecomment-1037199304
@hachikuji , thanks for the comments. I've updated the PR. Thanks.
--
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 #11749:
URL: https://github.com/apache/kafka/pull/11749#discussion_r805194799
##
File path:
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMakerConfig.java
##
@@ -93,17 +93,17 @@ public MirrorMakerConfig(Map
showuon commented on a change in pull request #10851:
URL: https://github.com/apache/kafka/pull/10851#discussion_r805156641
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/DefaultStandbyTaskAssignor.java
##
@@ -0,0 +1,67 @@
+/*
+ *
dengziming commented on pull request #11746:
URL: https://github.com/apache/kafka/pull/11746#issuecomment-1037750296
Hello @dajac @showuon, I found that we set this to a large enough value in
KAFKA-5324 so that we can overwrite per-call timeout with a lager value by
`AbstractOptions`. I
hachikuji merged pull request #11603:
URL: https://github.com/apache/kafka/pull/11603
--
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:
ijuma commented on a change in pull request #11754:
URL: https://github.com/apache/kafka/pull/11754#discussion_r805423796
##
File path: clients/src/main/java/org/apache/kafka/common/utils/Utils.java
##
@@ -764,10 +764,7 @@ public static ByteBuffer ensureCapacity(ByteBuffer
cadonna commented on a change in pull request #10851:
URL: https://github.com/apache/kafka/pull/10851#discussion_r805203233
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientTagAwareStandbyTaskAssignor.java
##
@@ -0,0 +1,289 @@
[
https://issues.apache.org/jira/browse/KAFKA-13615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17491742#comment-17491742
]
Guozhang Wang commented on KAFKA-13615:
---
[~timcosta] You mean your brokers are on the MSK right?
[
https://issues.apache.org/jira/browse/KAFKA-13437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17491738#comment-17491738
]
RivenSun commented on KAFKA-13437:
--
[~ijuma]
Thank you for your reply
I noticed early on that
ijuma commented on a change in pull request #11754:
URL: https://github.com/apache/kafka/pull/11754#discussion_r805423796
##
File path: clients/src/main/java/org/apache/kafka/common/utils/Utils.java
##
@@ -764,10 +764,7 @@ public static ByteBuffer ensureCapacity(ByteBuffer
[
https://issues.apache.org/jira/browse/KAFKA-13615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17491703#comment-17491703
]
Ismael Juma commented on KAFKA-13615:
-
The client version doesn't have to match the broker version.
ruanwenjun opened a new pull request #11754:
URL: https://github.com/apache/kafka/pull/11754
* It's better to initialize collection size when create a collection like
set, and the constructor like `HashSet(Collection c)` will
calculate the best initialize size, so we don't need to
[
https://issues.apache.org/jira/browse/KAFKA-13615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17491609#comment-17491609
]
Tim Costa commented on KAFKA-13615:
---
[~guozhang] we can reliably reproduce this issue, to a point. It
[
https://issues.apache.org/jira/browse/KAFKA-13437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17491550#comment-17491550
]
Ismael Juma commented on KAFKA-13437:
-
Also see KAFKA-7589.
> Broker parameter optimization:
[
https://issues.apache.org/jira/browse/KAFKA-9320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17491549#comment-17491549
]
Ismael Juma commented on KAFKA-9320:
[~yzang] Thanks for reporting the issue. Let's move the
[
https://issues.apache.org/jira/browse/KAFKA-13418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17491548#comment-17491548
]
Ismael Juma commented on KAFKA-13418:
-
[~skokoori] Thanks for the report. Can you please submit a
[
https://issues.apache.org/jira/browse/KAFKA-6706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma resolved KAFKA-6706.
Fix Version/s: 1.1.1
Resolution: Fixed
> NETWORK_EXCEPTION and REQUEST_TIMED_OUT in
[
https://issues.apache.org/jira/browse/KAFKA-4231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma resolved KAFKA-4231.
Resolution: Cannot Reproduce
> ZK metadata went inconsistent when migrating 0.10.0.0 -> 0.10.0.1
>
[
https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma resolved KAFKA-7304.
Fix Version/s: 2.0.1
Assignee: Rajini Sivaram
Resolution: Fixed
Marking as fixed
[
https://issues.apache.org/jira/browse/KAFKA-2561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17491540#comment-17491540
]
Ismael Juma commented on KAFKA-2561:
Java 16 improved TLS performance further:
[
https://issues.apache.org/jira/browse/KAFKA-2561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma resolved KAFKA-2561.
Resolution: Won't Do
> Optionally support OpenSSL for SSL/TLS
>
[
https://issues.apache.org/jira/browse/KAFKA-13474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17491538#comment-17491538
]
Ismael Juma commented on KAFKA-13474:
-
Thanks for the report. We should triage this before the next
[
https://issues.apache.org/jira/browse/KAFKA-13474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-13474:
Priority: Critical (was: Blocker)
> Regression in dynamic update of broker certificate
>
[
https://issues.apache.org/jira/browse/KAFKA-13474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-13474:
Fix Version/s: 3.2.0
> Regression in dynamic update of broker certificate
>
[
https://issues.apache.org/jira/browse/KAFKA-13474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-13474:
Priority: Blocker (was: Major)
> Regression in dynamic update of broker certificate
>
ruanwenjun opened a new pull request #11753:
URL: https://github.com/apache/kafka/pull/11753
I find there is no Apache License header in `suppressions.xml`, this pr is
adding the license header.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and
31 matches
Mail list logo
