predatorray commented on pull request #10525:
URL: https://github.com/apache/kafka/pull/10525#issuecomment-877575923
Hi @showuon. It looks like nobody else shared thought about this exception
for some time. I have changed to use the IllegalArgumentException instead of
the InvalidPartitionE
[
https://issues.apache.org/jira/browse/KAFKA-10675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis updated KAFKA-10675:
---
Fix Version/s: 2.7.2
2.6.3
> Error message from ConnectSc
kkonstantine merged pull request #9541:
URL: https://github.com/apache/kafka/pull/9541
--
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
showuon commented on a change in pull request #10794:
URL: https://github.com/apache/kafka/pull/10794#discussion_r667293695
##
File path: core/src/test/scala/unit/kafka/network/RequestChannelTest.scala
##
@@ -179,6 +184,108 @@ class RequestChannelTest {
assertTrue(isValid
showuon commented on a change in pull request #10794:
URL: https://github.com/apache/kafka/pull/10794#discussion_r667293513
##
File path: clients/src/main/java/org/apache/kafka/common/requests/ApiError.java
##
@@ -36,10 +38,21 @@
private final String message;
public
showuon commented on a change in pull request #10794:
URL: https://github.com/apache/kafka/pull/10794#discussion_r667293072
##
File path: core/src/test/scala/unit/kafka/network/RequestChannelTest.scala
##
@@ -179,6 +184,108 @@ class RequestChannelTest {
assertTrue(isValid
zhaohaidao commented on pull request #10969:
URL: https://github.com/apache/kafka/pull/10969#issuecomment-877512351
> @zhaohaidao , thanks for the PR. Left some comments. Thanks.
@showuon hi, Comments have been addressed. could you please continue to
review if you have time, thanks.
hachikuji commented on a change in pull request #10794:
URL: https://github.com/apache/kafka/pull/10794#discussion_r667245949
##
File path: core/src/test/scala/unit/kafka/network/RequestChannelTest.scala
##
@@ -179,6 +184,108 @@ class RequestChannelTest {
assertTrue(isVal
hachikuji commented on a change in pull request #10794:
URL: https://github.com/apache/kafka/pull/10794#discussion_r667244195
##
File path: core/src/test/scala/unit/kafka/network/RequestChannelTest.scala
##
@@ -179,6 +184,108 @@ class RequestChannelTest {
assertTrue(isVal
0x1991babe opened a new pull request #11014:
URL: https://github.com/apache/kafka/pull/11014
This is *extremely, extremely* minor.
We are using default values for some serialization logic, and I noticed in
doing a review for https://github.com/0x1991babe/kafka-protocol-rs/issues/1
t
[
https://issues.apache.org/jira/browse/KAFKA-13008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17378338#comment-17378338
]
John Roesler commented on KAFKA-13008:
--
Woah, this is an excellent find, [~showuon]
cmccabe commented on a change in pull request #10753:
URL: https://github.com/apache/kafka/pull/10753#discussion_r667240160
##
File path:
metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
##
@@ -1204,6 +1317,298 @@ void generateLeaderAndIsrUpdat
cmccabe commented on a change in pull request #10753:
URL: https://github.com/apache/kafka/pull/10753#discussion_r667238459
##
File path:
metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
##
@@ -1204,6 +1317,298 @@ void generateLeaderAndIsrUpdat
cmccabe commented on a change in pull request #10753:
URL: https://github.com/apache/kafka/pull/10753#discussion_r667232772
##
File path:
metadata/src/main/java/org/apache/kafka/controller/RemovingAndAddingReplicas.java
##
@@ -0,0 +1,214 @@
+/*
+ * Licensed to the Apache Softw
cmccabe commented on a change in pull request #10753:
URL: https://github.com/apache/kafka/pull/10753#discussion_r665801100
##
File path:
metadata/src/main/java/org/apache/kafka/controller/RemovingAndAddingReplicas.java
##
@@ -0,0 +1,214 @@
+/*
+ * Licensed to the Apache Softw
cmccabe commented on a change in pull request #10753:
URL: https://github.com/apache/kafka/pull/10753#discussion_r667232604
##
File path:
metadata/src/main/java/org/apache/kafka/controller/RemovingAndAddingReplicas.java
##
@@ -0,0 +1,214 @@
+/*
+ * Licensed to the Apache Softw
[
https://issues.apache.org/jira/browse/KAFKA-9705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis updated KAFKA-9705:
--
Fix Version/s: (was: 3.0.0)
> Zookeeper mutation protocols should be redire
[
https://issues.apache.org/jira/browse/KAFKA-10345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis updated KAFKA-10345:
---
Fix Version/s: (was: 3.0.0)
> Add auto reloading for trust/key store pat
vvcephei commented on a change in pull request #11003:
URL: https://github.com/apache/kafka/pull/11003#discussion_r667228608
##
File path: docs/streams/developer-guide/config-streams.html
##
@@ -600,8 +613,54 @@ default.windowed.value.serde.innermax.task.idle.ms
kkonstantine commented on a change in pull request #9541:
URL: https://github.com/apache/kafka/pull/9541#discussion_r667225730
##
File path:
connect/api/src/main/java/org/apache/kafka/connect/data/ConnectSchema.java
##
@@ -221,13 +221,7 @@ public static void validateValue(Stri
hachikuji opened a new pull request #11013:
URL: https://github.com/apache/kafka/pull/11013
When a node is serving as both broker and controller, we should only rely on
the controller to write new snapshots.
### Committer Checklist (excluded from commit message)
- [ ] Verify desig
hachikuji commented on a change in pull request #11011:
URL: https://github.com/apache/kafka/pull/11011#discussion_r667225066
##
File path: core/src/main/scala/kafka/server/KafkaConfig.scala
##
@@ -1975,6 +1975,8 @@ class KafkaConfig(val props: java.util.Map[_, _], doLog:
Bool
junrao commented on a change in pull request #10753:
URL: https://github.com/apache/kafka/pull/10753#discussion_r667223580
##
File path:
metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
##
@@ -1204,6 +1317,298 @@ void generateLeaderAndIsrUpdate
hachikuji commented on a change in pull request #11011:
URL: https://github.com/apache/kafka/pull/11011#discussion_r667216030
##
File path: core/src/main/scala/kafka/server/KafkaConfig.scala
##
@@ -1971,5 +1974,7 @@ class KafkaConfig(val props: java.util.Map[_, _], doLog:
Bool
hachikuji commented on a change in pull request #11011:
URL: https://github.com/apache/kafka/pull/11011#discussion_r667216030
##
File path: core/src/main/scala/kafka/server/KafkaConfig.scala
##
@@ -1971,5 +1974,7 @@ class KafkaConfig(val props: java.util.Map[_, _], doLog:
Bool
hachikuji commented on a change in pull request #11011:
URL: https://github.com/apache/kafka/pull/11011#discussion_r667216030
##
File path: core/src/main/scala/kafka/server/KafkaConfig.scala
##
@@ -1971,5 +1974,7 @@ class KafkaConfig(val props: java.util.Map[_, _], doLog:
Bool
hachikuji edited a comment on pull request #11012:
URL: https://github.com/apache/kafka/pull/11012#issuecomment-877459197
One more to fix is `UnregisterBroker`. We do not need this exposed on the
broker.
--
This is an automated message from the Apache Git Service.
To respond to the messa
hachikuji commented on pull request #11012:
URL: https://github.com/apache/kafka/pull/11012#issuecomment-877459197
One more to fix i s`UnregisterBroker`. We do not need this exposed on the
broker.
--
This is an automated message from the Apache Git Service.
To respond to the message, ple
hachikuji commented on a change in pull request #11012:
URL: https://github.com/apache/kafka/pull/11012#discussion_r667212406
##
File path:
clients/src/main/resources/common/message/CreatePartitionsRequest.json
##
@@ -16,7 +16,7 @@
{
"apiKey": 37,
"type": "request",
-
[
https://issues.apache.org/jira/browse/KAFKA-12493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis updated KAFKA-12493:
---
Fix Version/s: (was: 3.0.0)
> The controller should handle the consisten
[
https://issues.apache.org/jira/browse/KAFKA-13051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis updated KAFKA-13051:
---
Priority: Blocker (was: Major)
> Require Principal Serde to be defined for
[
https://issues.apache.org/jira/browse/KAFKA-12493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17378309#comment-17378309
]
Konstantine Karantasis commented on KAFKA-12493:
Thanks for the update [
[
https://issues.apache.org/jira/browse/KAFKA-13056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis updated KAFKA-13056:
---
Fix Version/s: (was: 3.0.0)
> Broker should not generate snapshots when
[
https://issues.apache.org/jira/browse/KAFKA-10345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17378306#comment-17378306
]
Konstantine Karantasis commented on KAFKA-10345:
Sorry. Wrong mentions.
[
https://issues.apache.org/jira/browse/KAFKA-12878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis updated KAFKA-12878:
---
Fix Version/s: (was: 3.0.0)
3.1.0
> Support --bootstr
[
https://issues.apache.org/jira/browse/KAFKA-12878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17378299#comment-17378299
]
Konstantine Karantasis commented on KAFKA-12878:
I wasn't able to find a
cmccabe commented on a change in pull request #10753:
URL: https://github.com/apache/kafka/pull/10753#discussion_r667204243
##
File path:
metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
##
@@ -1204,6 +1317,298 @@ void generateLeaderAndIsrUpdat
[
https://issues.apache.org/jira/browse/KAFKA-6840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17378297#comment-17378297
]
Konstantine Karantasis commented on KAFKA-6840:
---
[KIP-300|https://cwiki.apa
[
https://issues.apache.org/jira/browse/KAFKA-6840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis updated KAFKA-6840:
--
Fix Version/s: (was: 3.0.0)
> support windowing in ktable API
> ---
[
https://issues.apache.org/jira/browse/KAFKA-10046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis resolved KAFKA-10046.
Resolution: Fixed
> Deprecated PartitionGrouper config is ignored
> --
[
https://issues.apache.org/jira/browse/KAFKA-10046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17378294#comment-17378294
]
Konstantine Karantasis commented on KAFKA-10046:
[~ableegoldman] the two
[
https://issues.apache.org/jira/browse/KAFKA-12419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis resolved KAFKA-12419.
Resolution: Fixed
> Remove Deprecated APIs of Kafka Streams in 3.0
> -
[
https://issues.apache.org/jira/browse/KAFKA-12419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17378293#comment-17378293
]
Konstantine Karantasis commented on KAFKA-12419:
All the subtasks of thi
[
https://issues.apache.org/jira/browse/KAFKA-12499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis resolved KAFKA-12499.
Resolution: Fixed
> Adjust transaction timeout according to commit interva
[
https://issues.apache.org/jira/browse/KAFKA-9990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis updated KAFKA-9990:
--
Fix Version/s: (was: 3.0.0)
3.1.0
> Supporting transacti
[
https://issues.apache.org/jira/browse/KAFKA-9579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17378282#comment-17378282
]
Konstantine Karantasis commented on KAFKA-9579:
---
Feature freeze for AK 3.0
[
https://issues.apache.org/jira/browse/KAFKA-12802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis updated KAFKA-12802:
---
Fix Version/s: (was: 3.0.0)
3.1.0
> Add a file based
[
https://issues.apache.org/jira/browse/KAFKA-12641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17378286#comment-17378286
]
Konstantine Karantasis commented on KAFKA-12641:
Feature freeze for AK 3
[
https://issues.apache.org/jira/browse/KAFKA-12641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis updated KAFKA-12641:
---
Fix Version/s: (was: 3.0.0)
3.1.0
> Clear RemoteLogLe
[
https://issues.apache.org/jira/browse/KAFKA-12802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17378287#comment-17378287
]
Konstantine Karantasis commented on KAFKA-12802:
Feature freeze for AK 3
[
https://issues.apache.org/jira/browse/KAFKA-9990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17378284#comment-17378284
]
Konstantine Karantasis commented on KAFKA-9990:
---
Feature freeze for AK 3.0
[
https://issues.apache.org/jira/browse/KAFKA-9579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis updated KAFKA-9579:
--
Fix Version/s: (was: 3.0.0)
3.1.0
> RLM fetch implementa
[
https://issues.apache.org/jira/browse/KAFKA-9578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis updated KAFKA-9578:
--
Fix Version/s: (was: 3.0.0)
3.1.0
> Kafka Tiered Storage
[
https://issues.apache.org/jira/browse/KAFKA-9578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17378280#comment-17378280
]
Konstantine Karantasis commented on KAFKA-9578:
---
Feature freeze for AK 3.0
[
https://issues.apache.org/jira/browse/KAFKA-9550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17378278#comment-17378278
]
Konstantine Karantasis commented on KAFKA-9550:
---
Feature freeze for AK 3.0
[
https://issues.apache.org/jira/browse/KAFKA-9555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17378277#comment-17378277
]
Konstantine Karantasis commented on KAFKA-9555:
---
Feature freeze for AK 3.0
[
https://issues.apache.org/jira/browse/KAFKA-9555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis updated KAFKA-9555:
--
Fix Version/s: (was: 3.0.0)
3.1.0
> Topic-based implemen
[
https://issues.apache.org/jira/browse/KAFKA-9550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis updated KAFKA-9550:
--
Fix Version/s: (was: 3.0.0)
3.1.0
> RemoteLogManager imp
[
https://issues.apache.org/jira/browse/KAFKA-7739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17378276#comment-17378276
]
Konstantine Karantasis commented on KAFKA-7739:
---
Setting the target version
[
https://issues.apache.org/jira/browse/KAFKA-7739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis updated KAFKA-7739:
--
Fix Version/s: (was: 3.0.0)
3.1.0
> Kafka Tiered Storage
rondagostino commented on pull request #10991:
URL: https://github.com/apache/kafka/pull/10991#issuecomment-877430917
TL;DR: my preference is to skip the regex check rather than adding a new
message and carefully/appropriately grepping for it.
> I think you do need to special case th
hachikuji commented on pull request #11012:
URL: https://github.com/apache/kafka/pull/11012#issuecomment-877418762
While we're at it, I think we should be able to remove "broker" from the
listeners for `AllocateProducerIds`.
--
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/KAFKA-13053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-13053.
-
Fix Version/s: 3.0.0
Resolution: Fixed
> Bump frame version for KRaft records
> -
hachikuji commented on a change in pull request #11011:
URL: https://github.com/apache/kafka/pull/11011#discussion_r667174963
##
File path: docs/upgrade.html
##
@@ -21,6 +21,7 @@
Notable changes in
3.0.0
+Custom principal builder implementations specified through
pri
hachikuji commented on a change in pull request #10794:
URL: https://github.com/apache/kafka/pull/10794#discussion_r667171204
##
File path: core/src/test/scala/integration/kafka/server/RaftClusterTest.scala
##
@@ -29,7 +29,7 @@ import java.util
import java.util.Collections
im
mumrah opened a new pull request #11012:
URL: https://github.com/apache/kafka/pull/11012
--
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-unsu
[
https://issues.apache.org/jira/browse/KAFKA-13057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur reassigned KAFKA-13057:
Assignee: David Arthur
> Many broker RPCs are not enable in KRaft mode
>
dajac merged pull request #10998:
URL: https://github.com/apache/kafka/pull/10998
--
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...
dajac commented on pull request #10998:
URL: https://github.com/apache/kafka/pull/10998#issuecomment-877411273
Indeed, failures are not related. I am going to merge it. @0x1991babe Thanks
for the patch!
--
This is an automated message from the Apache Git Service.
To respond to the messag
David Arthur created KAFKA-13057:
Summary: Many broker RPCs are not enable in KRaft mode
Key: KAFKA-13057
URL: https://issues.apache.org/jira/browse/KAFKA-13057
Project: Kafka
Issue Type: Bug
Jason Gustafson created KAFKA-13056:
---
Summary: Broker should not generate snapshots when controller is
co-resident
Key: KAFKA-13056
URL: https://issues.apache.org/jira/browse/KAFKA-13056
Project: Ka
hachikuji commented on a change in pull request #11011:
URL: https://github.com/apache/kafka/pull/11011#discussion_r667164215
##
File path: docs/upgrade.html
##
@@ -21,6 +21,7 @@
Notable changes in
3.0.0
+A Principal Serde defenition is now required. A default has bee
hachikuji commented on a change in pull request #11011:
URL: https://github.com/apache/kafka/pull/11011#discussion_r667164215
##
File path: docs/upgrade.html
##
@@ -21,6 +21,7 @@
Notable changes in
3.0.0
+A Principal Serde defenition is now required. A default has bee
[
https://issues.apache.org/jira/browse/KAFKA-8295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17378253#comment-17378253
]
Sagar Rao commented on KAFKA-8295:
--
hey sorry to bug you on this again.. but wondering i
cmccabe merged pull request #11010:
URL: https://github.com/apache/kafka/pull/11010
--
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.
vamossagar12 commented on pull request #10877:
URL: https://github.com/apache/kafka/pull/10877#issuecomment-877398722
Thanks @ableegoldman i have fixed the merge conflict. Plz review whenever
you get the chance...
--
This is an automated message from the Apache Git Service.
To respond t
cmccabe merged pull request #10990:
URL: https://github.com/apache/kafka/pull/10990
--
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.
skaundinya15 commented on pull request #11000:
URL: https://github.com/apache/kafka/pull/11000#issuecomment-877386499
Thank you for the review @rajinisivaram, I applied the changes you suggested
to both this test as well as a very similar test in
`AuthorizerIntegrationTest.scala`. Please t
mumrah commented on pull request #11005:
URL: https://github.com/apache/kafka/pull/11005#issuecomment-877381458
Merged to trunk and 3.0
--
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 specif
dielhennr opened a new pull request #11011:
URL: https://github.com/apache/kafka/pull/11011
Adding a default PrincipalBuilderClassProp and requiring that any custom
config setting implements KafkaPrincipalSerde.
--
This is an automated message from the Apache Git Service.
To respond
mumrah merged pull request #11005:
URL: https://github.com/apache/kafka/pull/11005
--
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..
zhaohaidao commented on a change in pull request #10969:
URL: https://github.com/apache/kafka/pull/10969#discussion_r667115287
##
File path: core/src/test/scala/unit/kafka/server/KafkaConfigTest.scala
##
@@ -1054,7 +1054,8 @@ class KafkaConfigTest {
private def assertValidQu
rajinisivaram commented on a change in pull request #11002:
URL: https://github.com/apache/kafka/pull/11002#discussion_r667103591
##
File path:
clients/src/test/java/org/apache/kafka/clients/producer/KafkaProducerTest.java
##
@@ -172,6 +173,115 @@ public void
testOverwriteAck
[
https://issues.apache.org/jira/browse/KAFKA-7025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17378205#comment-17378205
]
Nikolai Lubiagov commented on KAFKA-7025:
-
Oh... so long time ago it was. Will ch
hachikuji commented on a change in pull request #11010:
URL: https://github.com/apache/kafka/pull/11010#discussion_r667105114
##
File path:
metadata/src/test/java/org/apache/kafka/controller/QuorumControllerTest.java
##
@@ -17,50 +17,34 @@
package org.apache.kafka.controlle
cmccabe commented on a change in pull request #11010:
URL: https://github.com/apache/kafka/pull/11010#discussion_r667102835
##
File path:
metadata/src/test/java/org/apache/kafka/controller/QuorumControllerTest.java
##
@@ -17,50 +17,34 @@
package org.apache.kafka.controller;
junrao commented on a change in pull request #10579:
URL: https://github.com/apache/kafka/pull/10579#discussion_r667102624
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManager.java
##
@@ -0,0 +1,432 @@
+/*
+
[
https://issues.apache.org/jira/browse/KAFKA-13051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17378193#comment-17378193
]
Ryan Dielhenn commented on KAFKA-13051:
---
[~kkonstantine] Yes it is.
> Require Pri
hachikuji opened a new pull request #11010:
URL: https://github.com/apache/kafka/pull/11010
This patch bumps the default frame version for kraft records from 0 to 1. At
the same time, we reset all records versions back to 0 and we enable flexible
version support for `UnregisterBrokerRecord
xvrl commented on a change in pull request #11008:
URL: https://github.com/apache/kafka/pull/11008#discussion_r667078995
##
File path: core/src/main/scala/kafka/tools/ConsoleConsumer.scala
##
@@ -392,25 +401,25 @@ object ConsoleConsumer extends Logging {
}
}
- privat
xvrl commented on a change in pull request #11008:
URL: https://github.com/apache/kafka/pull/11008#discussion_r667075504
##
File path: core/src/main/scala/kafka/tools/ConsoleConsumer.scala
##
@@ -191,9 +191,15 @@ object ConsoleConsumer extends Logging {
.withRequiredArg
cmccabe commented on a change in pull request #10794:
URL: https://github.com/apache/kafka/pull/10794#discussion_r667072949
##
File path: core/src/test/scala/integration/kafka/server/RaftClusterTest.scala
##
@@ -29,7 +29,7 @@ import java.util
import java.util.Collections
impo
cmccabe commented on a change in pull request #10990:
URL: https://github.com/apache/kafka/pull/10990#discussion_r667066884
##
File path:
core/src/test/scala/unit/kafka/server/metadata/BrokerMetadataSnapshotterTest.scala
##
@@ -0,0 +1,105 @@
+/**
+ * Licensed to the Apache Sof
cmccabe commented on a change in pull request #10990:
URL: https://github.com/apache/kafka/pull/10990#discussion_r667066884
##
File path:
core/src/test/scala/unit/kafka/server/metadata/BrokerMetadataSnapshotterTest.scala
##
@@ -0,0 +1,105 @@
+/**
+ * Licensed to the Apache Sof
cmccabe commented on a change in pull request #10990:
URL: https://github.com/apache/kafka/pull/10990#discussion_r667062463
##
File path:
core/src/test/scala/unit/kafka/server/metadata/BrokerMetadataListenerTest.scala
##
@@ -77,5 +80,124 @@ class BrokerMetadataListenerTest {
cmccabe commented on a change in pull request #10990:
URL: https://github.com/apache/kafka/pull/10990#discussion_r667060078
##
File path:
core/src/test/scala/unit/kafka/server/metadata/BrokerMetadataListenerTest.scala
##
@@ -77,5 +80,124 @@ class BrokerMetadataListenerTest {
cmccabe commented on a change in pull request #10990:
URL: https://github.com/apache/kafka/pull/10990#discussion_r667059387
##
File path:
core/src/test/scala/unit/kafka/server/metadata/BrokerMetadataListenerTest.scala
##
@@ -18,28 +18,31 @@
package kafka.server.metadata
im
zhaohaidao commented on a change in pull request #10969:
URL: https://github.com/apache/kafka/pull/10969#discussion_r667059331
##
File path:
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientSnapshotTest.java
##
@@ -48,6 +48,9 @@
import static org.junit.jupiter.api.Asse
[
https://issues.apache.org/jira/browse/KAFKA-13055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexey Kashavkin updated KAFKA-13055:
-
Affects Version/s: 2.8.0
> Security without JAAS file
> --
>
>
Alexey Kashavkin created KAFKA-13055:
Summary: Security without JAAS file
Key: KAFKA-13055
URL: https://issues.apache.org/jira/browse/KAFKA-13055
Project: Kafka
Issue Type: Bug
1 - 100 of 133 matches
Mail list logo