muralibasani commented on code in PR #16325:
URL: https://github.com/apache/kafka/pull/16325#discussion_r1672845320
##
core/src/main/scala/kafka/tools/StorageTool.scala:
##
@@ -698,6 +663,42 @@ object StorageTool extends Logging {
voterSet
}
+ def
muralibasani commented on code in PR #16325:
URL: https://github.com/apache/kafka/pull/16325#discussion_r1672833818
##
core/src/main/scala/kafka/tools/StorageTool.scala:
##
@@ -112,20 +112,21 @@ object StorageTool extends Logging {
setNodeId(config.nodeId).
jsancio commented on code in PR #16325:
URL: https://github.com/apache/kafka/pull/16325#discussion_r1668893365
##
core/src/main/scala/kafka/tools/StorageTool.scala:
##
@@ -300,19 +301,19 @@ object StorageTool extends Logging {
}
private def getUserScramCredentialRecord(
muralibasani commented on code in PR #16325:
URL: https://github.com/apache/kafka/pull/16325#discussion_r1665647113
##
core/src/main/scala/kafka/tools/StorageTool.scala:
##
@@ -503,24 +537,29 @@ object StorageTool extends Logging {
}
def formatCommand(
-stream:
muralibasani commented on code in PR #16325:
URL: https://github.com/apache/kafka/pull/16325#discussion_r1665644755
##
core/src/main/scala/kafka/tools/StorageTool.scala:
##
@@ -102,6 +111,23 @@ object StorageTool extends Logging {
setClusterId(clusterId).
muralibasani commented on code in PR #16325:
URL: https://github.com/apache/kafka/pull/16325#discussion_r1661035915
##
core/src/test/scala/unit/kafka/tools/StorageToolTest.scala:
##
@@ -285,6 +362,49 @@ Found problem:
"Expected the default metadata.version to be
muralibasani commented on PR #16325:
URL: https://github.com/apache/kafka/pull/16325#issuecomment-2200108407
@jsancio , updated with controller option
```
./bin/kafka-storage.sh format -t $KAFKA_CLUSTER_ID -c
config/kraft/server.properties -q 1@localhost:9093
jsancio commented on code in PR #16325:
URL: https://github.com/apache/kafka/pull/16325#discussion_r1651072253
##
core/src/main/scala/kafka/tools/StorageTool.scala:
##
@@ -102,6 +109,11 @@ object StorageTool extends Logging {
setClusterId(clusterId).
jsancio commented on PR #16325:
URL: https://github.com/apache/kafka/pull/16325#issuecomment-2173806713
> cat
/tmp/kraft-combined-logs/__cluster_metadata-0/-00.checkpoint
@muralibasani You can use `bin/kafka-dump-log --cluster-metadata-decoder
--files
jsancio commented on code in PR #16325:
URL: https://github.com/apache/kafka/pull/16325#discussion_r1642996134
##
core/src/main/scala/kafka/tools/StorageTool.scala:
##
@@ -46,6 +51,8 @@ import scala.collection.mutable.ArrayBuffer
object StorageTool extends Logging {
+ val
muralibasani commented on PR #16325:
URL: https://github.com/apache/kafka/pull/16325#issuecomment-2170896788
@jsancio Output looks like below.
./bin/kafka-storage.sh format -t $KAFKA_CLUSTER_ID -c
config/kraft/server.properties -s
muralibasani opened a new pull request, #16325:
URL: https://github.com/apache/kafka/pull/16325
Resolves : https://issues.apache.org/jira/browse/KAFKA-16518
Adds a new argument "standalone" to kafka-storage.sh
If standalone mode, creates a checkpoint file in metadata dir
muralibasani closed pull request #16094: KAFKA-16518; Adding standalone
argument for storage
URL: https://github.com/apache/kafka/pull/16094
--
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
muralibasani commented on code in PR #16094:
URL: https://github.com/apache/kafka/pull/16094#discussion_r1619077543
##
core/src/main/scala/kafka/tools/StorageTool.scala:
##
@@ -452,21 +460,68 @@ object StorageTool extends Logging {
stream.println("All of the log
muralibasani commented on code in PR #16094:
URL: https://github.com/apache/kafka/pull/16094#discussion_r1619077543
##
core/src/main/scala/kafka/tools/StorageTool.scala:
##
@@ -452,21 +460,68 @@ object StorageTool extends Logging {
stream.println("All of the log
muralibasani commented on code in PR #16094:
URL: https://github.com/apache/kafka/pull/16094#discussion_r1619109614
##
core/src/main/scala/kafka/tools/StorageTool.scala:
##
@@ -452,21 +460,68 @@ object StorageTool extends Logging {
stream.println("All of the log
muralibasani commented on code in PR #16094:
URL: https://github.com/apache/kafka/pull/16094#discussion_r1619109614
##
core/src/main/scala/kafka/tools/StorageTool.scala:
##
@@ -452,21 +460,68 @@ object StorageTool extends Logging {
stream.println("All of the log
muralibasani commented on code in PR #16094:
URL: https://github.com/apache/kafka/pull/16094#discussion_r1619109614
##
core/src/main/scala/kafka/tools/StorageTool.scala:
##
@@ -452,21 +460,68 @@ object StorageTool extends Logging {
stream.println("All of the log
muralibasani commented on code in PR #16094:
URL: https://github.com/apache/kafka/pull/16094#discussion_r1619077543
##
core/src/main/scala/kafka/tools/StorageTool.scala:
##
@@ -452,21 +460,68 @@ object StorageTool extends Logging {
stream.println("All of the log
19 matches
Mail list logo
