[
https://issues.apache.org/jira/browse/KAFKA-7575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17491263#comment-17491263
]
Jacek commented on KAFKA-7575:
--
Hey I have been using it for a week on our test in the company and so far it
[
https://issues.apache.org/jira/browse/KAFKA-7575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17491263#comment-17491263
]
Jacek edited comment on KAFKA-7575 at 2/12/22, 5:21 AM:
Hey I have been using it
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
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:
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 /
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
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
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
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
[
https://issues.apache.org/jira/browse/KAFKA-7575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17491225#comment-17491225
]
Ivan Sager commented on KAFKA-7575:
---
FYI, I am now using kafka_2.13-3.1.0 on windows and so far so
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
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
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
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
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:
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
#
[
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
[
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 #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 @@
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:
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
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
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
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
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
[
https://issues.apache.org/jira/browse/KAFKA-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17491093#comment-17491093
]
Matthias J. Sax commented on KAFKA-6647:
Not sure if I can follow the details – it might be best
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:
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.
[
https://issues.apache.org/jira/browse/KAFKA-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17491083#comment-17491083
]
Rob Leland edited comment on KAFKA-6647 at 2/11/22, 6:36 PM:
-
4 Unit tests
[
https://issues.apache.org/jira/browse/KAFKA-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17491083#comment-17491083
]
Rob Leland edited comment on KAFKA-6647 at 2/11/22, 6:33 PM:
-
4 Unit tests
[
https://issues.apache.org/jira/browse/KAFKA-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17491083#comment-17491083
]
Rob Leland commented on KAFKA-6647:
---
4 Unit tests are silently swallowing exception attributed to this
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 {
[
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
[
https://issues.apache.org/jira/browse/KAFKA-12256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17491076#comment-17491076
]
Guozhang Wang commented on KAFKA-12256:
---
Hello [~rleslie] yeah I think we can close this ticket
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,
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
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
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,
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
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
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:
[
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
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:
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
[
https://issues.apache.org/jira/browse/KAFKA-8872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490902#comment-17490902
]
dengziming commented on KAFKA-8872:
---
I don't think this can be done with 3.2.0 since this KIP involves
[
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
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:
[
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
> ---
[
https://issues.apache.org/jira/browse/KAFKA-8872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490884#comment-17490884
]
Bruno Cadonna commented on KAFKA-8872:
--
Hi [~jolshan], [~lucasbradstreet], and [~dengziming],
Is
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
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
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() {
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) {
[
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
>
[
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-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-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-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:
[
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-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
>
>
>
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
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:
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
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
[
https://issues.apache.org/jira/browse/KAFKA-13463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490761#comment-17490761
]
Luke Chen commented on KAFKA-13463:
---
I must check your KIP! :)
Thanks for the effort and the
66 matches
Mail list logo
