This repository was archived by the owner on Sep 26, 2024. It is now read-only.
forked from apache/kafka
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
KAFKA-7793: Improve the Trogdor command line. (apache#6133)
* Allow the Trogdor agent to be started in "exec mode", where it simply runs a single task and exits after it is complete. * For AgentClient and CoordinatorClient, allow the user to pass the path to a file containing JSON, instead of specifying the JSON object in the command-line text itself. This means that we can get rid of the bash scripts whose only function was to load task specs into a bash string and run a Trogdor command. * Print dates and times in a human-readable way, rather than as numbers of milliseconds. * When listing tasks or workers, output human-readable tables of information. * Allow the user to filter on task ID name, task ID pattern, or task state. * Support a --json flag to provide raw JSON output if desired. Reviewed-by: David Arthur <[email protected]>, Stanislav Kozlovski <[email protected]>
- Loading branch information
Showing
26 changed files
with
1,204 additions
and
407 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,12 +1,7 @@ | ||
| Vagrantfile.local | ||
|
|
||
| .idea/ | ||
|
|
||
| *.pyc | ||
| *.ipynb | ||
|
|
||
| .DS_Store | ||
|
|
||
| .ducktape | ||
| results/ | ||
| *.json |
This file was deleted.
Oops, something went wrong.
This file was deleted.
Oops, something went wrong.
This file was deleted.
Oops, something went wrong.
This file was deleted.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,34 @@ | ||
| // Licensed to the Apache Software Foundation (ASF) under one or more | ||
| // contributor license agreements. See the NOTICE file distributed with | ||
| // this work for additional information regarding copyright ownership. | ||
| // The ASF licenses this file to You under the Apache License, Version 2.0 | ||
| // (the "License"); you may not use this file except in compliance with | ||
| // the License. You may obtain a copy of the License at | ||
| // | ||
| // http://www.apache.org/licenses/LICENSE-2.0 | ||
| // | ||
| // Unless required by applicable law or agreed to in writing, software | ||
| // distributed under the License is distributed on an "AS IS" BASIS, | ||
| // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| // See the License for the specific language governing permissions and | ||
| // limitations under the License. | ||
|
|
||
| // | ||
| // An example task specification for running a round trip test in Trogdor. | ||
| // See TROGDOR.md for details. | ||
| // | ||
|
|
||
| { | ||
| "class": "org.apache.kafka.trogdor.workload.RoundTripWorkloadSpec", | ||
| "durationMs": 10000000, | ||
| "clientNode": "node0", | ||
| "bootstrapServers": "localhost:9092", | ||
| "targetMessagesPerSec": 1000, | ||
| "maxMessages": 100, | ||
| "activeTopics": { | ||
| "round_trip_topic[0-1]": { | ||
| "numPartitions": 2, | ||
| "replicationFactor": 1 | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,31 @@ | ||
| // Licensed to the Apache Software Foundation (ASF) under one or more | ||
| // contributor license agreements. See the NOTICE file distributed with | ||
| // this work for additional information regarding copyright ownership. | ||
| // The ASF licenses this file to You under the Apache License, Version 2.0 | ||
| // (the "License"); you may not use this file except in compliance with | ||
| // the License. You may obtain a copy of the License at | ||
| // | ||
| // http://www.apache.org/licenses/LICENSE-2.0 | ||
| // | ||
| // Unless required by applicable law or agreed to in writing, software | ||
| // distributed under the License is distributed on an "AS IS" BASIS, | ||
| // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| // See the License for the specific language governing permissions and | ||
| // limitations under the License. | ||
|
|
||
| // | ||
| // An example task specification for running a consumer benchmark in Trogdor. | ||
| // See TROGDOR.md for details. | ||
| // | ||
|
|
||
| { | ||
| "class": "org.apache.kafka.trogdor.workload.ConsumeBenchSpec", | ||
| "durationMs": 10000000, | ||
| "consumerNode": "node0", | ||
| "bootstrapServers": "localhost:9092", | ||
| "targetMessagesPerSec": 1000, | ||
| "threadsPerWorker": 5, | ||
| "consumerGroup": "cg", | ||
| "maxMessages": 10000, | ||
| "activeTopics": [ "foo[1-3]" ] | ||
| } |
Oops, something went wrong.