Skip to content

Commit

Permalink
minor cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
milenkovicm committed Jun 18, 2024
1 parent 99c3e24 commit ab8055a
Showing 1 changed file with 2 additions and 5 deletions.
7 changes: 2 additions & 5 deletions src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -58,14 +58,14 @@ impl Redpanda {
},
];

//ExecCommand::new(vec![format!("rpk topic create {} -p {}", topic_name, partitions)])
// ExecCommand::new(vec![format!("rpk topic create {} -p {}", topic_name, partitions)])
ExecCommand::new(vec![
String::from("rpk"),
String::from("topic"),
String::from("create"),
String::from(topic_name),
String::from("-p"),
format!("{}", partitions),
partitions.to_string(),
])
.with_cmd_ready_condition(CmdWaitFor::Duration {
length: std::time::Duration::from_secs(1),
Expand All @@ -81,8 +81,6 @@ impl Redpanda {
// ```

impl Image for Redpanda {
//type Args = RedpandaArgs;

fn name(&self) -> &str {
"docker.redpanda.com/redpandadata/redpanda"
}
Expand All @@ -91,7 +89,6 @@ impl Image for Redpanda {
vec![
"-c",
"/usr/bin/rpk redpanda start --mode dev-container --node-id 0 --set redpanda.auto_create_topics_enabled=true"
,
]
.into_iter()
}
Expand Down

0 comments on commit ab8055a

Please sign in to comment.