diff --git a/Dockerfile b/Dockerfile
index a2413537..0f284bd9 100644
--- a/Dockerfile
+++ b/Dockerfile
@@ -17,7 +17,7 @@ RUN --mount=type=cache,target=/usr/local/cargo/registry \
 ENV PATH /root/.foundry/bin:$PATH
 RUN curl -L https://foundry.paradigm.xyz | bash && foundryup
 
-RUN apt-get update && apt-get install librdkafka-dev && rm -rf /var/lib/apt/lists/*
+RUN apt-get update && apt-get install --yes librdkafka-dev && rm -rf /var/lib/apt/lists/*
 
 # copy the application
 COPY . .
diff --git a/web3_proxy/src/bin/web3_proxy_cli/example.rs b/web3_proxy/src/bin/web3_proxy_cli/example.rs
index ed0ee02d..51e2fa64 100644
--- a/web3_proxy/src/bin/web3_proxy_cli/example.rs
+++ b/web3_proxy/src/bin/web3_proxy_cli/example.rs
@@ -1,15 +1,15 @@
 use argh::FromArgs;
 
 #[derive(FromArgs, PartialEq, Debug)]
-/// Second subcommand.
-#[argh(subcommand, name = "two")]
-pub struct SubCommandTwo {
+/// An example subcommand. Copy paste this into a new file.
+#[argh(subcommand, name = "example")]
+pub struct ExampleSubcommand {
     #[argh(switch)]
     /// whether to fooey
     fooey: bool,
 }
 
-impl SubCommandTwo {
+impl ExampleSubcommand {
     pub async fn main(self) -> anyhow::Result<()> {
         todo!()
     }
diff --git a/web3_proxy/src/bin/web3_proxy_cli/main.rs b/web3_proxy/src/bin/web3_proxy_cli/main.rs
index 82c95655..31ed40fb 100644
--- a/web3_proxy/src/bin/web3_proxy_cli/main.rs
+++ b/web3_proxy/src/bin/web3_proxy_cli/main.rs
@@ -13,6 +13,7 @@ mod pagerduty;
 mod popularity_contest;
 mod proxyd;
 mod rpc_accounting;
+mod search_kafka;
 mod sentryd;
 mod transfer_key;
 mod user_export;
@@ -80,6 +81,7 @@ enum SubCommand {
     PopularityContest(popularity_contest::PopularityContestSubCommand),
     Proxyd(proxyd::ProxydSubCommand),
     RpcAccounting(rpc_accounting::RpcAccountingSubCommand),
+    SearchKafka(search_kafka::SearchKafkaSubCommand),
     Sentryd(sentryd::SentrydSubCommand),
     TransferKey(transfer_key::TransferKeySubCommand),
     UserExport(user_export::UserExportSubCommand),
@@ -374,6 +376,7 @@ fn main() -> anyhow::Result<()> {
                 x.main(pagerduty_async, top_config).await
             }
             SubCommand::PopularityContest(x) => x.main().await,
+            SubCommand::SearchKafka(x) => x.main().await,
             SubCommand::Sentryd(x) => {
                 if cli_config.sentry_url.is_none() {
                     warn!("sentry_url is not set! Logs will only show in this console");