postgres sink problem

Jet-Engine · Dec 15, 2023 · ccad842 · ccad842
1 parent b485891
commit ccad842
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/examples/postgres-sink.rs b/examples/postgres-sink.rs
@@ -46,8 +46,8 @@ async fn postgres_agent(stream: CStream, _ctx: Context<()>) -> Result<()> {
 fn main() {
     let mut app = Callysto::new();
 
-    app.with_name("elasticsearch-app");
-    app.agent("elastic-agent", app.topic("example"), postgres_agent);
+    app.with_name("postgres-sink-app");
+    app.agent("postgres-agent", app.topic("example"), postgres_agent);
 
     app.run();
 }