[
https://issues.apache.org/jira/browse/KAFKA-13653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-13653:
--
Description:
Currently, client metadata update has 2 situations:
# partition leader change
#
dengziming commented on a change in pull request #11667:
URL: https://github.com/apache/kafka/pull/11667#discussion_r801337197
##
File path: core/src/test/scala/unit/kafka/server/ApiVersionsRequestTest.scala
##
@@ -17,41 +17,35 @@
package kafka.server
-import
showuon commented on a change in pull request #11722:
URL: https://github.com/apache/kafka/pull/11722#discussion_r801293429
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java
##
@@ -578,41 +594,46 @@ private boolean
jasonk000 commented on a change in pull request #11721:
URL: https://github.com/apache/kafka/pull/11721#discussion_r801255679
##
File path: clients/src/main/java/org/apache/kafka/common/utils/ByteUtils.java
##
@@ -386,18 +386,39 @@ public static void writeDouble(double value,
showuon commented on a change in pull request #11688:
URL: https://github.com/apache/kafka/pull/11688#discussion_r801269210
##
File path: core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala
##
@@ -1791,4 +1793,33 @@ class PlaintextConsumerTest extends
twmb commented on a change in pull request #11721:
URL: https://github.com/apache/kafka/pull/11721#discussion_r801276342
##
File path: clients/src/main/java/org/apache/kafka/common/utils/ByteUtils.java
##
@@ -386,18 +386,39 @@ public static void writeDouble(double value,
guozhangwang commented on pull request #11705:
URL: https://github.com/apache/kafka/pull/11705#issuecomment-1032215108
Thanks @showuon , making a pass soon.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
jasonk000 commented on a change in pull request #11722:
URL: https://github.com/apache/kafka/pull/11722#discussion_r801259547
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java
##
@@ -578,41 +594,46 @@ private boolean
jasonk000 commented on a change in pull request #11721:
URL: https://github.com/apache/kafka/pull/11721#discussion_r801255679
##
File path: clients/src/main/java/org/apache/kafka/common/utils/ByteUtils.java
##
@@ -386,18 +386,39 @@ public static void writeDouble(double value,
[
https://issues.apache.org/jira/browse/KAFKA-13639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenqing Luo updated KAFKA-13639:
Attachment: image.png
> NotEnoughReplicasException for __consumer_offsets topic due to out of
[
https://issues.apache.org/jira/browse/KAFKA-13639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenqing Luo updated KAFKA-13639:
Attachment: (was: image.png)
> NotEnoughReplicasException for __consumer_offsets topic due to
showuon commented on pull request #10367:
URL: https://github.com/apache/kafka/pull/10367#issuecomment-1032172509
@kkonstantine , call for review and comments. Thanks.
--
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-12495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17488571#comment-17488571
]
Luke Chen commented on KAFKA-12495:
---
[~kkonstantine] , there are some users faced this issue and would
showuon commented on a change in pull request #11737:
URL: https://github.com/apache/kafka/pull/11737#discussion_r801230532
##
File path: docs/upgrade.html
##
@@ -19,56 +19,6 @@
Sunil created KAFKA-13652:
-
Summary: encrypt the passwords in kafka jaas conf file
Key: KAFKA-13652
URL: https://issues.apache.org/jira/browse/KAFKA-13652
Project: Kafka
Issue Type: Test
mjsax closed pull request #10897:
URL: https://github.com/apache/kafka/pull/10897
--
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 #10897:
URL: https://github.com/apache/kafka/pull/10897#issuecomment-1032151335
Thanks for getting back. Closing this PR.
--
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
[
https://issues.apache.org/jira/browse/KAFKA-13492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13492:
Fix Version/s: 3.2.0
> IQ Parity: queries for key/value store range and scan
>
[
https://issues.apache.org/jira/browse/KAFKA-8410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-8410:
---
Description:
KIP-478:
[
https://issues.apache.org/jira/browse/KAFKA-8410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-8410:
---
Labels: kip tech-debt (was: tech-debt)
> Strengthen the types of Processors, at least in
hachikuji commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r801214042
##
File path:
metadata/src/main/java/org/apache/kafka/controller/AclControlManager.java
##
@@ -0,0 +1,232 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/KAFKA-8410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-8410.
Resolution: Fixed
This feature (KIP–478:
[
https://issues.apache.org/jira/browse/KAFKA-8410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-8410:
---
Fix Version/s: 2.7.0
> Strengthen the types of Processors, at least in the DSL, maybe in the
[
https://issues.apache.org/jira/browse/KAFKA-13651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe updated KAFKA-13651:
-
Labels: kip-500 kip-801 (was: )
> StandardAuthorizer should implement all the required log4j
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r801176180
##
File path:
metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizer.java
##
@@ -0,0 +1,179 @@
+/*
+ * Licensed to the Apache
Colin McCabe created KAFKA-13651:
Summary: StandardAuthorizer should implement all the required
log4j stuff
Key: KAFKA-13651
URL: https://issues.apache.org/jira/browse/KAFKA-13651
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-13646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe updated KAFKA-13646:
-
Labels: kip-500 kip-801 (was: kip-500)
> Implement KIP-801: KRaft authorizer
>
[
https://issues.apache.org/jira/browse/KAFKA-13649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe updated KAFKA-13649:
-
Labels: kip-500 kip-801 (was: kip-500)
> StandardAuthorizer should not finish loading until it
[
https://issues.apache.org/jira/browse/KAFKA-13650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe updated KAFKA-13650:
-
Labels: kip-500 kip-801 (was: kip-500)
> Add StandardAuthorizer JMH benchmark
>
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r801175105
##
File path:
core/src/main/scala/kafka/server/metadata/BrokerMetadataPublisher.scala
##
@@ -209,6 +212,33 @@ class BrokerMetadataPublisher(conf:
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r801174494
##
File path:
metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAcl.java
##
@@ -0,0 +1,176 @@
+/*
+ * Licensed to the Apache Software
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r801174122
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -3366,7 +3366,7 @@ class KafkaApis(val requestChannel: RequestChannel,
})
}
hachikuji commented on a change in pull request #11616:
URL: https://github.com/apache/kafka/pull/11616#discussion_r801162756
##
File path: config/kraft/broker.properties
##
@@ -31,22 +31,24 @@ controller.quorum.voters=1@localhost:9093
# Socket
Colin McCabe created KAFKA-13650:
Summary: Add StandardAuthorizer JMH benchmark
Key: KAFKA-13650
URL: https://issues.apache.org/jira/browse/KAFKA-13650
Project: Kafka
Issue Type: Improvement
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r801172349
##
File path:
metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizerData.java
##
@@ -0,0 +1,430 @@
+/*
+ * Licensed to the
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r801170612
##
File path:
metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizer.java
##
@@ -0,0 +1,179 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/KAFKA-13649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe updated KAFKA-13649:
-
Labels: kip-500 (was: )
> StandardAuthorizer should not finish loading until it reads up to
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r801167657
##
File path:
metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizer.java
##
@@ -0,0 +1,179 @@
+/*
+ * Licensed to the Apache
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r801167657
##
File path:
metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizer.java
##
@@ -0,0 +1,179 @@
+/*
+ * Licensed to the Apache
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r801167657
##
File path:
metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizer.java
##
@@ -0,0 +1,179 @@
+/*
+ * Licensed to the Apache
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r801167657
##
File path:
metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizer.java
##
@@ -0,0 +1,179 @@
+/*
+ * Licensed to the Apache
Colin McCabe created KAFKA-13649:
Summary: StandardAuthorizer should not finish loading until it
reads up to the high water mark
Key: KAFKA-13649
URL: https://issues.apache.org/jira/browse/KAFKA-13649
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r801166256
##
File path:
metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizer.java
##
@@ -0,0 +1,179 @@
+/*
+ * Licensed to the Apache
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r801164871
##
File path:
metadata/src/main/java/org/apache/kafka/metadata/authorizer/ClusterMetadataAuthorizer.java
##
@@ -0,0 +1,127 @@
+/*
+ * Licensed to the
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r801162104
##
File path:
metadata/src/main/java/org/apache/kafka/metadata/authorizer/ClusterMetadataAuthorizer.java
##
@@ -0,0 +1,127 @@
+/*
+ * Licensed to the
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r801161757
##
File path:
metadata/src/main/java/org/apache/kafka/metadata/authorizer/ClusterMetadataAuthorizer.java
##
@@ -0,0 +1,127 @@
+/*
+ * Licensed to the
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r801160455
##
File path:
metadata/src/main/java/org/apache/kafka/controller/AclControlManager.java
##
@@ -0,0 +1,232 @@
+/*
+ * Licensed to the Apache Software
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r801160275
##
File path: core/src/test/scala/unit/kafka/utils/TestUtils.scala
##
@@ -2106,32 +2106,65 @@ object TestUtils extends Logging {
s"There still are
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r801159039
##
File path:
core/src/test/scala/unit/kafka/integration/KafkaServerTestHarness.scala
##
@@ -254,11 +254,23 @@ abstract class KafkaServerTestHarness
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r801159039
##
File path:
core/src/test/scala/unit/kafka/integration/KafkaServerTestHarness.scala
##
@@ -254,11 +254,23 @@ abstract class KafkaServerTestHarness
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r801159039
##
File path:
core/src/test/scala/unit/kafka/integration/KafkaServerTestHarness.scala
##
@@ -254,11 +254,23 @@ abstract class KafkaServerTestHarness
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r801158397
##
File path:
core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala
##
@@ -321,7 +340,11 @@ class AuthorizerIntegrationTest extends
twmb commented on a change in pull request #11721:
URL: https://github.com/apache/kafka/pull/11721#discussion_r801157664
##
File path: clients/src/main/java/org/apache/kafka/common/utils/ByteUtils.java
##
@@ -386,18 +386,39 @@ public static void writeDouble(double value,
hachikuji commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r801157654
##
File path: core/src/main/scala/kafka/server/ControllerServer.scala
##
@@ -173,8 +174,12 @@ class ControllerServer(
setMetrics(new
twmb commented on a change in pull request #11721:
URL: https://github.com/apache/kafka/pull/11721#discussion_r801157664
##
File path: clients/src/main/java/org/apache/kafka/common/utils/ByteUtils.java
##
@@ -386,18 +386,39 @@ public static void writeDouble(double value,
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r801155285
##
File path:
core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala
##
@@ -147,7 +150,12 @@ class AuthorizerIntegrationTest extends
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r801155285
##
File path:
core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala
##
@@ -147,7 +150,12 @@ class AuthorizerIntegrationTest extends
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r801154386
##
File path:
core/src/main/scala/kafka/server/metadata/BrokerMetadataPublisher.scala
##
@@ -209,6 +212,33 @@ class BrokerMetadataPublisher(conf:
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r801154386
##
File path:
core/src/main/scala/kafka/server/metadata/BrokerMetadataPublisher.scala
##
@@ -209,6 +212,33 @@ class BrokerMetadataPublisher(conf:
hachikuji commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r801154082
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -3366,7 +3366,7 @@ class KafkaApis(val requestChannel: RequestChannel,
})
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r801150649
##
File path: core/src/main/scala/kafka/server/ControllerServer.scala
##
@@ -173,8 +174,12 @@ class ControllerServer(
setMetrics(new
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r801150649
##
File path: core/src/main/scala/kafka/server/ControllerServer.scala
##
@@ -173,8 +174,12 @@ class ControllerServer(
setMetrics(new
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r801150649
##
File path: core/src/main/scala/kafka/server/ControllerServer.scala
##
@@ -173,8 +174,12 @@ class ControllerServer(
setMetrics(new
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r801150649
##
File path: core/src/main/scala/kafka/server/ControllerServer.scala
##
@@ -173,8 +174,12 @@ class ControllerServer(
setMetrics(new
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r801149465
##
File path: core/src/main/scala/kafka/server/ControllerApis.scala
##
@@ -689,7 +689,7 @@ class ControllerApis(val requestChannel: RequestChannel,
ijuma merged pull request #11306:
URL: https://github.com/apache/kafka/pull/11306
--
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-12879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-12879:
-
Assignee: Philip Nee (was: Kirk True)
> Compatibility break in Admin.listOffsets()
>
hachikuji commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r800941876
##
File path: core/src/main/scala/kafka/server/ControllerApis.scala
##
@@ -689,7 +689,7 @@ class ControllerApis(val requestChannel: RequestChannel,
David Arthur created KAFKA-13648:
Summary: KRaft ClusterInstance does not allow for deferred start
Key: KAFKA-13648
URL: https://issues.apache.org/jira/browse/KAFKA-13648
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-13647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17488400#comment-17488400
]
Bruno Cadonna commented on KAFKA-13647:
---
[~guozhang] Nice catch!
> RocksDb metrics
[
https://issues.apache.org/jira/browse/KAFKA-13647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17488332#comment-17488332
]
Guozhang Wang commented on KAFKA-13647:
---
TLDR: I think the `NO_FILE_OPENS` statistics is right,
hachikuji commented on a change in pull request #11667:
URL: https://github.com/apache/kafka/pull/11667#discussion_r800933651
##
File path: core/src/test/scala/unit/kafka/server/ApiVersionsRequestTest.scala
##
@@ -17,41 +17,35 @@
package kafka.server
-import
hachikuji opened a new pull request #11737:
URL: https://github.com/apache/kafka/pull/11737
I accidentally pulled in the 3.2 notes into the 3.1 branch after
cherry-picking https://github.com/apache/kafka/pull/11691.
### Committer Checklist (excluded from commit message)
- [ ]
guozhangwang commented on pull request #10525:
URL: https://github.com/apache/kafka/pull/10525#issuecomment-1031749531
Merged to trunk, thanks @predatorray for the patch!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
guozhangwang merged pull request #10525:
URL: https://github.com/apache/kafka/pull/10525
--
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 commented on a change in pull request #11672:
URL: https://github.com/apache/kafka/pull/11672#discussion_r800884869
##
File path: core/src/test/scala/kafka/common/InterBrokerSendThreadTest.scala
##
@@ -134,36 +139,45 @@ class InterBrokerSendThreadTest {
val
tombentley commented on a change in pull request #11672:
URL: https://github.com/apache/kafka/pull/11672#discussion_r800800519
##
File path: core/src/test/scala/kafka/common/InterBrokerSendThreadTest.scala
##
@@ -134,36 +139,45 @@ class InterBrokerSendThreadTest {
val
predatorray commented on a change in pull request #10525:
URL: https://github.com/apache/kafka/pull/10525#discussion_r800756743
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java
##
@@ -1305,10 +1305,16 @@ private ClusterResourceListeners
[
https://issues.apache.org/jira/browse/KAFKA-13647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17488169#comment-17488169
]
Sylvain Le Gouellec commented on KAFKA-13647:
-
Hi [~cadonna] -, First thanks for your
[
https://issues.apache.org/jira/browse/KAFKA-13647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sylvain Le Gouellec updated KAFKA-13647:
Attachment: image-2022-02-07-16-06-25-304.png
> RocksDb metrics
[
https://issues.apache.org/jira/browse/KAFKA-13647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sylvain Le Gouellec updated KAFKA-13647:
Attachment: image-2022-02-07-16-06-53-164.png
> RocksDb metrics
[
https://issues.apache.org/jira/browse/KAFKA-13647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sylvain Le Gouellec updated KAFKA-13647:
Attachment: image-2022-02-07-16-06-39-821.png
> RocksDb metrics
ijuma merged pull request #11736:
URL: https://github.com/apache/kafka/pull/11736
--
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:
dengziming commented on a change in pull request #11667:
URL: https://github.com/apache/kafka/pull/11667#discussion_r800700262
##
File path: core/src/test/scala/unit/kafka/server/ApiVersionsRequestTest.scala
##
@@ -17,41 +17,35 @@
package kafka.server
-import
hgeraldino closed pull request #11515:
URL: https://github.com/apache/kafka/pull/11515
--
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:
dengziming commented on a change in pull request #11209:
URL: https://github.com/apache/kafka/pull/11209#discussion_r800646883
##
File path: raft/src/main/java/org/apache/kafka/raft/RaftUtil.java
##
@@ -159,4 +161,18 @@ static boolean
[
https://issues.apache.org/jira/browse/KAFKA-13599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-13599:
--
Labels: (was: streams)
> Upgrade RocksDB to 6.27.3
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-13638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17488071#comment-17488071
]
Bruno Cadonna commented on KAFKA-13638:
---
[~Lejon] I put the following code around
Sylvain Le Gouellec created KAFKA-13647:
---
Summary: RocksDb metrics 'number-open-files' is not correct
Key: KAFKA-13647
URL: https://issues.apache.org/jira/browse/KAFKA-13647
Project: Kafka
Ge commented on pull request #11447:
URL: https://github.com/apache/kafka/pull/11447#issuecomment-1031269712
> My rationale is that, we do some optimizations at the end of the building
phase which may move some repartition up in the topology etc, which would
effectively change the
[
https://issues.apache.org/jira/browse/KAFKA-13599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-13599:
--
Fix Version/s: 3.2.0
> Upgrade RocksDB to 6.27.3
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-13599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-13599:
--
Labels: streams (was: )
> Upgrade RocksDB to 6.27.3
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-13641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17487976#comment-17487976
]
Mohammad Yousuf Minhaj Zia commented on KAFKA-13641:
To be clear I do like the
showuon commented on a change in pull request #11584:
URL: https://github.com/apache/kafka/pull/11584#discussion_r800428095
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java
##
@@ -1516,4 +1527,20 @@ RebalanceProtocol
ableegoldman commented on a change in pull request #11584:
URL: https://github.com/apache/kafka/pull/11584#discussion_r800368829
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java
##
@@ -1516,4 +1527,20 @@
[
https://issues.apache.org/jira/browse/KAFKA-9837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17487938#comment-17487938
]
dengziming commented on KAFKA-9837:
---
Thank you [~cmccabe] , your concern make sense to me. it seems
96 matches
Mail list logo