# This tells Benthos: Use the 'sql_poller' template as the input
input:
  sql_poller:
    dsn: "postgres://yugabyte@yugabytedb-2:5433/yugabyte?sslmode=disable"
    table_name: "request_logs"
    id_column: "received_at" # Or 'id' if you use the hashed string

# The output sends the polled data back to NATS
# output:
#   nats_jetstream:
#     urls: [ "nats:4222" ]
#     subject: "public.request_logs"
#     stream: "fact_stream" 
#     manage_stream: true # This is the key setting