[
https://issues.apache.org/jira/browse/KAFKA-13652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17492333#comment-17492333
]
Sunil commented on KAFKA-13652:
---
Hi Support,
Can i know an update on this case please.
showuon commented on pull request #11757:
URL: https://github.com/apache/kafka/pull/11757#issuecomment-1039793039
Thanks for the clarification! LGTM!
--
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
hachikuji commented on a change in pull request #11616:
URL: https://github.com/apache/kafka/pull/11616#discussion_r806399392
##
File path: config/kraft/server.properties
##
@@ -31,22 +31,24 @@ controller.quorum.voters=1@localhost:9093
# Socket Se
[
https://issues.apache.org/jira/browse/KAFKA-13589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17492327#comment-17492327
]
Luke Chen commented on KAFKA-13589:
---
Close this ticket since KAFKA-13598 is merged. T
dongjinleekr commented on pull request #11579:
URL: https://github.com/apache/kafka/pull/11579#issuecomment-1039726499
@ijuma If you don't mind [CVE
WS-2021-0419](https://github.com/protocolbuffers/protobuf/issues/9457)
introduced by gson 2.8.6. This PR is to fix it.
--
This is an autom
guozhangwang commented on a change in pull request #11759:
URL: https://github.com/apache/kafka/pull/11759#discussion_r806350276
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/ReadOnlySessionStore.java
##
@@ -226,14 +323,14 @@
* Get the value of key f
[
https://issues.apache.org/jira/browse/KAFKA-13655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17492280#comment-17492280
]
Matthias J. Sax edited comment on KAFKA-13655 at 2/15/22, 12:23 AM:
--
[
https://issues.apache.org/jira/browse/KAFKA-13655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17492280#comment-17492280
]
Matthias J. Sax commented on KAFKA-13655:
-
Missed you message from a week ago –
mjsax opened a new pull request #11759:
URL: https://github.com/apache/kafka/pull/11759
The JavaDocs explaining the `findSession` search interval is correct, but
hard to understand. We should be more explicit how it works.
--
This is an automated message from the Apache Git Service.
To r
ijuma merged pull request #11757:
URL: https://github.com/apache/kafka/pull/11757
--
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...
C0urante opened a new pull request #11758:
URL: https://github.com/apache/kafka/pull/11758
The docs are a little misleading and some users can be confused about the
exact behavior of this property.
References:
- [LogReporter::report and
LogReporter::message](https://github.com/ap
[
https://issues.apache.org/jira/browse/KAFKA-6419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Hamill reassigned KAFKA-6419:
--
Assignee: (was: Joel Hamill)
> Menu order in Streams docs incorrect
>
[
https://issues.apache.org/jira/browse/KAFKA-6197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Hamill reassigned KAFKA-6197:
--
Assignee: (was: Joel Hamill)
> Difficult to get to the Kafka Streams javadocs
> --
[
https://issues.apache.org/jira/browse/KAFKA-6823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17492164#comment-17492164
]
Bruno Cadonna edited comment on KAFKA-6823 at 2/14/22, 6:46 PM:
---
[
https://issues.apache.org/jira/browse/KAFKA-6823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17492164#comment-17492164
]
Bruno Cadonna commented on KAFKA-6823:
--
I would prefer to create a new ticket for th
ijuma commented on pull request #11757:
URL: https://github.com/apache/kafka/pull/11757#issuecomment-1039385776
Btw, I made these changes because Spark has upgraded to 3.1.0 and there was
some confusion regarding the compatibility implications of the upgrade.
--
This is an automated mess
ijuma commented on pull request #11757:
URL: https://github.com/apache/kafka/pull/11757#issuecomment-1039384837
@hachikuji Thanks. Yes, I intend to fix those two branches so that they
match what we have here excluding the 3.2 section.
--
This is an automated message from the Apache Git S
ijuma commented on a change in pull request #11757:
URL: https://github.com/apache/kafka/pull/11757#discussion_r806096638
##
File path: docs/upgrade.html
##
@@ -69,6 +69,13 @@ Upgrading to
3.1.0 from any vers
+Notable changes in
3.1.1
Review comment:
Good ca
hachikuji commented on a change in pull request #11757:
URL: https://github.com/apache/kafka/pull/11757#discussion_r806091862
##
File path: docs/upgrade.html
##
@@ -69,6 +69,13 @@ Upgrading to
3.1.0 from any vers
+Notable changes in
3.1.1
Review comment:
My
srdo closed pull request #6030:
URL: https://github.com/apache/kafka/pull/6030
--
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...@ka
srdo commented on pull request #6030:
URL: https://github.com/apache/kafka/pull/6030#issuecomment-1039304783
This is way out of date, and there didn't seem to be much interest. Closing.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on t
ijuma opened a new pull request #11757:
URL: https://github.com/apache/kafka/pull/11757
* Mention `acks=1` to `acks=all` change in 3.0.0 upgrade docs
* Have a separate section for 3.0.1 and 3.1.1 as some may skip the
3.0.0/3.1.0 section when upgrading to a bug fix.
### Committ
[
https://issues.apache.org/jira/browse/KAFKA-10619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-10619:
Summary: Enable producer idempotence by default (KIP-679) (was: Producer
will enable EOS by defau
[
https://issues.apache.org/jira/browse/KAFKA-13589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17492050#comment-17492050
]
Ismael Juma commented on KAFKA-13589:
-
[~showuon] Can we close this?
> fix flaky
>
[
https://issues.apache.org/jira/browse/KAFKA-13598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-13598:
Description:
In KAFKA-10619, we intended to enable idempotence by default, but this was not
achie
[
https://issues.apache.org/jira/browse/KAFKA-13598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-13598:
Description:
In KAFKA-10619, we intended to enable idempotence by default, but this was not
achie
[
https://issues.apache.org/jira/browse/KAFKA-6823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17492048#comment-17492048
]
Mickael Maison commented on KAFKA-6823:
---
This test is still constantly failing:
- h
[
https://issues.apache.org/jira/browse/KAFKA-10619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17492047#comment-17492047
]
Ismael Juma commented on KAFKA-10619:
-
See KAFKA-13598 for details on a bug that pre
[
https://issues.apache.org/jira/browse/KAFKA-10619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-10619:
Summary: Producer will enable EOS by default (KIP-679) (was: Producer will
enable EOS by default)
jsancio commented on a change in pull request #11733:
URL: https://github.com/apache/kafka/pull/11733#discussion_r805920416
##
File path: core/src/main/scala/kafka/server/AlterIsrManager.scala
##
@@ -250,23 +260,35 @@ class DefaultAlterIsrManager(
val partitionResponse
jsancio commented on a change in pull request #11733:
URL: https://github.com/apache/kafka/pull/11733#discussion_r805916080
##
File path: clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java
##
@@ -110,6 +110,14 @@
LIST_TRANSACTIONS(ApiMessageType.LIST_TRANS
mimaison opened a new pull request #11756:
URL: https://github.com/apache/kafka/pull/11756
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgr
[
https://issues.apache.org/jira/browse/KAFKA-13655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490197#comment-17490197
]
Mario Mastrodicasa edited comment on KAFKA-13655 at 2/14/22, 2:30 PM:
[
https://issues.apache.org/jira/browse/KAFKA-13655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17492023#comment-17492023
]
Mario Mastrodicasa commented on KAFKA-13655:
[~mjsax] had you grant writes o
jsancio commented on pull request #11732:
URL: https://github.com/apache/kafka/pull/11732#issuecomment-1039148342
@ahuang98 It looks like some of these tests check that the `ConfigCommand`'s
command line parser and rejects certain command line arguments. Those tests
don't need a ZK or KRaf
ijuma commented on pull request #11579:
URL: https://github.com/apache/kafka/pull/11579#issuecomment-1039130031
Should we wait until they fix these issues in spotBugs? It doesn't look like
the cost/benefit in upgrading here isn't favorable.
--
This is an automated message from the Apache
mimaison commented on pull request #11748:
URL: https://github.com/apache/kafka/pull/11748#issuecomment-1039105856
@ryannedolan Can you take a look?
--
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-6823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna resolved KAFKA-6823.
--
Resolution: Fixed
> Transient failure in DynamicBrokerReconfigurationTest.testThreadPoolResize
[
https://issues.apache.org/jira/browse/KAFKA-6823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17491997#comment-17491997
]
Bruno Cadonna commented on KAFKA-6823:
--
I am going to close this ticket since it see
[
https://issues.apache.org/jira/browse/KAFKA-13418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17491996#comment-17491996
]
Ismael Juma commented on KAFKA-13418:
-
cc [~rajinisiva...@gmail.com]
> Brokers dis
lkokhreidze commented on a change in pull request #10851:
URL: https://github.com/apache/kafka/pull/10851#discussion_r805830410
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientTagAwareStandbyTaskAssignor.java
##
@@ -0,0 +1,289
showuon merged pull request #10832:
URL: https://github.com/apache/kafka/pull/10832
--
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 #10832:
URL: https://github.com/apache/kafka/pull/10832#issuecomment-1039025180
failed tests are also appeared in trunk branch test results.
```
Build / JDK 11 and Scala 2.13 /
org.apache.kafka.connect.integration.RebalanceSourceConnectorsIntegrationT
lkokhreidze commented on a change in pull request #10851:
URL: https://github.com/apache/kafka/pull/10851#discussion_r805782141
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientTagAwareStandbyTaskAssignor.java
##
@@ -0,0 +1,289
keashem opened a new pull request #11755:
URL: https://github.com/apache/kafka/pull/11755
The MetricTest testRemoveInactiveMetrics() should have tested to remove
inactive metrics， but it was not tested the sensor s2 when time passed，the code
should be modified to test sensor s2
#
ruanwenjun commented on a change in pull request #11754:
URL: https://github.com/apache/kafka/pull/11754#discussion_r805769215
##
File path: clients/src/main/java/org/apache/kafka/common/utils/Utils.java
##
@@ -764,10 +764,7 @@ public static ByteBuffer ensureCapacity(ByteBuffer
dongjinleekr commented on a change in pull request #11586:
URL: https://github.com/apache/kafka/pull/11586#discussion_r805725430
##
File path: clients/src/main/java/org/apache/kafka/common/network/Selector.java
##
@@ -1305,44 +1314,62 @@ private Sensor sensor(String name, Senso
[
https://issues.apache.org/jira/browse/KAFKA-13666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17491938#comment-17491938
]
Bruno Cadonna commented on KAFKA-13666:
---
[~rleland] Thank you for the ticket and t
[
https://issues.apache.org/jira/browse/KAFKA-13435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-13435.
-
Reviewer: Jason Gustafson
Resolution: Fixed
> Static membership protocol should let the le
[
https://issues.apache.org/jira/browse/KAFKA-13435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-13435:
Summary: Static membership protocol should let the leader skip assignment
(KIP-814) (was: Group w
dongjinleekr commented on a change in pull request #11586:
URL: https://github.com/apache/kafka/pull/11586#discussion_r805725430
##
File path: clients/src/main/java/org/apache/kafka/common/network/Selector.java
##
@@ -1305,44 +1314,62 @@ private Sensor sensor(String name, Senso
dajac merged pull request #11688:
URL: https://github.com/apache/kafka/pull/11688
--
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...
[
https://issues.apache.org/jira/browse/KAFKA-13666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-13666:
--
Component/s: streams
> Tests should not ignore exceptions for supported OS
> -
dongjinleekr commented on a change in pull request #11586:
URL: https://github.com/apache/kafka/pull/11586#discussion_r805720823
##
File path: clients/src/main/java/org/apache/kafka/common/network/Selector.java
##
@@ -1144,7 +1149,11 @@ public void close() {
public Sel
0.5, and rebased onto the latest trunk. It seems
like there are a bunch of false positives in the recent version of spotbugs
(below) but, I verified that none of them are affecting.
