From ccad84262c89ae46c509a8312e2fbc2383a75751 Mon Sep 17 00:00:00 2001 From: Theo Bulut Date: Fri, 15 Dec 2023 16:01:48 +0100 Subject: [PATCH] postgres sink problem --- examples/postgres-sink.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/examples/postgres-sink.rs b/examples/postgres-sink.rs index 0ad2b3d..c017208 100644 --- 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(); }