[
https://issues.apache.org/jira/browse/KAFKA-13463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490761#comment-17490761
]
Luke Chen commented on KAFKA-13463:
---
I must check your KIP! :)
Thanks for the effort
dajac commented on pull request #11746:
URL: https://github.com/apache/kafka/pull/11746#issuecomment-1036029927
I wonder why we did this in the first place. Is it because the request
timeout is handled by the admin client itself? If this is the case, it might
not be a good idea to change t
showuon commented on pull request #11746:
URL: https://github.com/apache/kafka/pull/11746#issuecomment-1036034155
@dajac , looks like you're right.
[KAFKA-5324](https://issues.apache.org/jira/browse/KAFKA-5324) changed the
value from `reqeust timeout config value` to 1 hour, to have per-ca
dengziming closed pull request #11746:
URL: https://github.com/apache/kafka/pull/11746
--
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-unsubs
dengziming commented on pull request #11746:
URL: https://github.com/apache/kafka/pull/11746#issuecomment-1036037690
Yes, it's handled by the admin client itself, I will recheck this logic,
thank you @dajac @showuon
--
This is an automated message from the Apache Git Service.
To respond
[
https://issues.apache.org/jira/browse/KAFKA-13435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-13435:
--
Fix Version/s: 3.2.0
> Group won't consume partitions added after static member restart
>
[
https://issues.apache.org/jira/browse/KAFKA-13549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-13549:
--
Fix Version/s: 3.2.0
> Add "delete interval" config
>
>
>
[
https://issues.apache.org/jira/browse/KAFKA-13494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-13494:
--
Fix Version/s: 3.2.0
> Session and Window Queries for IQv2
> -
[
https://issues.apache.org/jira/browse/KAFKA-13479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-13479:
--
Fix Version/s: 3.2.0
> Interactive Query v2
>
>
> Key: KA
[
https://issues.apache.org/jira/browse/KAFKA-13410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-13410:
--
Fix Version/s: 3.2.0
> KRaft Upgrades
> --
>
> Key: KAFKA-13410
>
[
https://issues.apache.org/jira/browse/KAFKA-12473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-12473:
--
Fix Version/s: 3.2.0
> Make the "cooperative-sticky, range" as the default assignor
>
[
https://issues.apache.org/jira/browse/KAFKA-12399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-12399:
--
Fix Version/s: 3.2.0
> Deprecate Log4J Appender
>
>
>
[
https://issues.apache.org/jira/browse/KAFKA-10733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-10733:
--
Fix Version/s: (was: 3.2.0)
> Enforce exception thrown for KafkaProducer txn APIs
> --
dengziming commented on a change in pull request #11747:
URL: https://github.com/apache/kafka/pull/11747#discussion_r804572420
##
File path: metadata/src/main/java/org/apache/kafka/image/ProducerIdsImage.java
##
@@ -50,7 +50,7 @@ public void write(Consumer> out) {
dengziming commented on a change in pull request #11603:
URL: https://github.com/apache/kafka/pull/11603#discussion_r804576005
##
File path:
shell/src/test/java/org/apache/kafka/shell/MetadataNodeManagerTest.java
##
@@ -290,4 +293,47 @@ public void testClientQuotaRecord() {
showuon commented on pull request #11746:
URL: https://github.com/apache/kafka/pull/11746#issuecomment-1036126819
@dengziming , I'm thinking if we should add some comment to this 1 hour
setting, so that it won't confuse other developers next time. WDYT?
--
This is an automated message fr
dengziming commented on a change in pull request #11603:
URL: https://github.com/apache/kafka/pull/11603#discussion_r804599430
##
File path: shell/src/main/java/org/apache/kafka/shell/MetadataNodeManager.java
##
@@ -318,6 +320,16 @@ private void handleCommitImpl(MetadataRecordT
[
https://issues.apache.org/jira/browse/KAFKA-8872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490884#comment-17490884
]
Bruno Cadonna commented on KAFKA-8872:
--
Hi [~jolshan], [~lucasbradstreet], and [~den
[
https://issues.apache.org/jira/browse/KAFKA-12251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dengziming resolved KAFKA-12251.
Resolution: Won't Do
> Add topic ID support to StopReplica
> ---
>
dengziming closed pull request #10075:
URL: https://github.com/apache/kafka/pull/10075
--
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-unsubs
[
https://issues.apache.org/jira/browse/KAFKA-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-10357:
--
Fix Version/s: (was: 3.2.0)
> Handle accidental deletion of repartition-topics as exceptio
[
https://issues.apache.org/jira/browse/KAFKA-8872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490902#comment-17490902
]
dengziming commented on KAFKA-8872:
---
I don't think this can be done with 3.2.0 since th
dajac commented on a change in pull request #11688:
URL: https://github.com/apache/kafka/pull/11688#discussion_r804630897
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinator.java
##
@@ -211,7 +211,13 @@ protected void onJo
mimaison merged pull request #11333:
URL: https://github.com/apache/kafka/pull/11333
--
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-13577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison resolved KAFKA-13577.
Fix Version/s: 3.2.0
Resolution: Fixed
> Replace EasyMock and PowerMock with Mockit
mimaison merged pull request #11674:
URL: https://github.com/apache/kafka/pull/11674
--
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
mumrah commented on a change in pull request #11747:
URL: https://github.com/apache/kafka/pull/11747#discussion_r804748320
##
File path:
metadata/src/main/java/org/apache/kafka/controller/ProducerIdControlManager.java
##
@@ -33,49 +33,50 @@
public class ProducerIdControlManag
mumrah commented on a change in pull request #11747:
URL: https://github.com/apache/kafka/pull/11747#discussion_r804748320
##
File path:
metadata/src/main/java/org/apache/kafka/controller/ProducerIdControlManager.java
##
@@ -33,49 +33,50 @@
public class ProducerIdControlManag
jsancio commented on a change in pull request #11745:
URL: https://github.com/apache/kafka/pull/11745#discussion_r804762258
##
File path: core/src/main/scala/kafka/server/ControllerApis.scala
##
@@ -725,13 +731,7 @@ class ControllerApis(val requestChannel: RequestChannel,
junrao commented on a change in pull request #11390:
URL: https://github.com/apache/kafka/pull/11390#discussion_r804843541
##
File path:
clients/src/main/java/org/apache/kafka/common/utils/ChildFirstClassLoader.java
##
@@ -0,0 +1,131 @@
+/*
+ * Licensed to the Apache Software
webfrank commented on pull request #10550:
URL: https://github.com/apache/kafka/pull/10550#issuecomment-1036433573
Hi, know this is not the right place but I didn't find any sample
configuration to use AclAuthorizer with KRaft enabled. If I add the line
`authorizer.class.name=kafka.securit
hachikuji commented on a change in pull request #11745:
URL: https://github.com/apache/kafka/pull/11745#discussion_r804872295
##
File path: core/src/main/scala/kafka/server/ControllerApis.scala
##
@@ -725,13 +731,7 @@ class ControllerApis(val requestChannel: RequestChannel,
[
https://issues.apache.org/jira/browse/KAFKA-12256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17491076#comment-17491076
]
Guozhang Wang commented on KAFKA-12256:
---
Hello [~rleslie] yeah I think we can clos
[
https://issues.apache.org/jira/browse/KAFKA-12256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-12256.
---
Fix Version/s: 3.2.0
Resolution: Fixed
> auto commit causes delays due to retriable U
hachikuji commented on a change in pull request #11667:
URL: https://github.com/apache/kafka/pull/11667#discussion_r804886945
##
File path: core/src/test/scala/unit/kafka/server/KafkaApisTest.scala
##
@@ -891,6 +890,7 @@ class KafkaApisTest {
testForwardableApi(ApiKeys.DEL
[
https://issues.apache.org/jira/browse/KAFKA-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17491083#comment-17491083
]
Rob Leland commented on KAFKA-6647:
---
4 Unit tests are silently swallowing exception att
[
https://issues.apache.org/jira/browse/KAFKA-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17491083#comment-17491083
]
Rob Leland edited comment on KAFKA-6647 at 2/11/22, 6:33 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17491083#comment-17491083
]
Rob Leland edited comment on KAFKA-6647 at 2/11/22, 6:36 PM:
-
mjsax commented on pull request #11584:
URL: https://github.com/apache/kafka/pull/11584#issuecomment-1036514041
Thanks -- it's also ok to first just file Jira's for flaky tests -- I often
don't know the code base (core/connect)... Of course, trying to fix them right
away is even better.
mjsax merged pull request #11584:
URL: https://github.com/apache/kafka/pull/11584
--
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-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17491093#comment-17491093
]
Matthias J. Sax commented on KAFKA-6647:
Not sure if I can follow the details – i
hachikuji commented on a change in pull request #11603:
URL: https://github.com/apache/kafka/pull/11603#discussion_r804998909
##
File path: shell/src/main/java/org/apache/kafka/shell/MetadataNodeManager.java
##
@@ -318,6 +320,16 @@ private void handleCommitImpl(MetadataRecordTy
mimaison opened a new pull request #11748:
URL: https://github.com/apache/kafka/pull/11748
…-syncs
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (inc
hachikuji commented on a change in pull request #11603:
URL: https://github.com/apache/kafka/pull/11603#discussion_r804998909
##
File path: shell/src/main/java/org/apache/kafka/shell/MetadataNodeManager.java
##
@@ -318,6 +320,16 @@ private void handleCommitImpl(MetadataRecordTy
artemlivshits commented on a change in pull request #11688:
URL: https://github.com/apache/kafka/pull/11688#discussion_r805024350
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinator.java
##
@@ -211,7 +211,13 @@ protected v
mimaison opened a new pull request #11749:
URL: https://github.com/apache/kafka/pull/11749
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgr
hachikuji merged pull request #11745:
URL: https://github.com/apache/kafka/pull/11745
--
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-unsubsc
hachikuji commented on a change in pull request #11733:
URL: https://github.com/apache/kafka/pull/11733#discussion_r803180976
##
File path: clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java
##
@@ -110,6 +110,14 @@
LIST_TRANSACTIONS(ApiMessageType.LIST_TRA
[
https://issues.apache.org/jira/browse/KAFKA-13661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-13661:
Fix Version/s: 3.2.0
3.1.1
> KRaft uses the wrong permission for adding
[
https://issues.apache.org/jira/browse/KAFKA-13661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-13661.
-
Resolution: Fixed
> KRaft uses the wrong permission for adding topic partitions
> --
hachikuji commented on a change in pull request #11616:
URL: https://github.com/apache/kafka/pull/11616#discussion_r805070981
##
File path: config/kraft/controller.properties
##
@@ -31,21 +31,16 @@ controller.quorum.voters=1@localhost:9093
# Socke
hachikuji merged pull request #11747:
URL: https://github.com/apache/kafka/pull/11747
--
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-unsubsc
hachikuji commented on a change in pull request #11667:
URL: https://github.com/apache/kafka/pull/11667#discussion_r805083314
##
File path:
core/src/test/scala/unit/kafka/server/CreateTopicsRequestWithForwardingTest.scala
##
@@ -26,14 +26,19 @@ import scala.jdk.CollectionConve
dengziming commented on a change in pull request #11667:
URL: https://github.com/apache/kafka/pull/11667#discussion_r805085878
##
File path:
core/src/test/scala/unit/kafka/server/CreateTopicsRequestWithForwardingTest.scala
##
@@ -26,14 +26,19 @@ import scala.jdk.CollectionConv
dengziming commented on pull request #11746:
URL: https://github.com/apache/kafka/pull/11746#issuecomment-1036847160
This is a good idea @showuon, I will add some comment to explain why we use
different setting here compared to KafkaConsumer and KafkaProducer.
--
This is an automated me
dengziming commented on a change in pull request #11603:
URL: https://github.com/apache/kafka/pull/11603#discussion_r805087020
##
File path: shell/src/main/java/org/apache/kafka/shell/MetadataNodeManager.java
##
@@ -318,6 +320,16 @@ private void handleCommitImpl(MetadataRecordT
[
https://issues.apache.org/jira/browse/KAFKA-7575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17491225#comment-17491225
]
Ivan Sager commented on KAFKA-7575:
---
FYI, I am now using kafka_2.13-3.1.0 on windows a
showuon commented on a change in pull request #11616:
URL: https://github.com/apache/kafka/pull/11616#discussion_r805101525
##
File path: config/kraft/controller.properties
##
@@ -31,21 +31,16 @@ controller.quorum.voters=1@localhost:9093
# Socket
showuon commented on a change in pull request #11616:
URL: https://github.com/apache/kafka/pull/11616#discussion_r805101777
##
File path: config/kraft/controller.properties
##
@@ -31,21 +31,16 @@ controller.quorum.voters=1@localhost:9093
# Socket
ableegoldman opened a new pull request #11750:
URL: https://github.com/apache/kafka/pull/11750
Previously we were only verifying the new query could be added after we had
already inserted it into the TopologyMetadata, so we need to move the
validation upfront.
Also adds a test case
guozhangwang commented on pull request #11750:
URL: https://github.com/apache/kafka/pull/11750#issuecomment-1036983791
@ableegoldman the change LGTM, but streams:checkstyleMain failed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
vvcephei commented on pull request #11534:
URL: https://github.com/apache/kafka/pull/11534#issuecomment-1036985910
Ok, looks like the streams failures were environmental (as they seemed). The
others are unrelated:
```
[Build / JDK 11 and Scala 2.13 /
kafka.api.ConsumerBounceTest.test
vvcephei merged pull request #11534:
URL: https://github.com/apache/kafka/pull/11534
--
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 #11534:
URL: https://github.com/apache/kafka/pull/11534#issuecomment-1036986385
Thanks so much, @jeqo !
--
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 spe
[
https://issues.apache.org/jira/browse/KAFKA-7575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17491263#comment-17491263
]
Jacek commented on KAFKA-7575:
--
Hey I have been using it for a week on our test in the compa
[
https://issues.apache.org/jira/browse/KAFKA-7575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17491263#comment-17491263
]
Jacek edited comment on KAFKA-7575 at 2/12/22, 5:21 AM:
Hey I hav
66 matches
Mail list logo
