From d91cf70ae346cbf613ce5c1cfad2ae8a28c71d1c Mon Sep 17 00:00:00 2001
From: Sandeep Kumar <83278309+tsdk02@users.noreply.github.com>
Date: Fri, 30 May 2025 13:01:05 +0530
Subject: [PATCH] fix(kafka): add correct topic name for connector-logs for
 docker config and local development (#8169)

---
 config/development.toml                                      | 2 +-
 config/docker_compose.toml                                   | 2 +-
 crates/analytics/docs/clickhouse/scripts/authentications.sql | 4 ++--
 3 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/config/development.toml b/config/development.toml
index 19e33b45f8..d6b5e89174 100644
--- a/config/development.toml
+++ b/config/development.toml
@@ -1028,7 +1028,7 @@ intent_analytics_topic = "hyperswitch-payment-intent-events"
 attempt_analytics_topic = "hyperswitch-payment-attempt-events"
 refund_analytics_topic = "hyperswitch-refund-events"
 api_logs_topic = "hyperswitch-api-log-events"
-connector_logs_topic = "hyperswitch-connector-api-events"
+connector_logs_topic = "hyperswitch-outgoing-connector-events"
 outgoing_webhook_logs_topic = "hyperswitch-outgoing-webhook-events"
 dispute_analytics_topic = "hyperswitch-dispute-events"
 audit_events_topic = "hyperswitch-audit-events"
diff --git a/config/docker_compose.toml b/config/docker_compose.toml
index 1ddef849d1..f1954a86fa 100644
--- a/config/docker_compose.toml
+++ b/config/docker_compose.toml
@@ -893,7 +893,7 @@ intent_analytics_topic = "hyperswitch-payment-intent-events"
 attempt_analytics_topic = "hyperswitch-payment-attempt-events"
 refund_analytics_topic = "hyperswitch-refund-events"
 api_logs_topic = "hyperswitch-api-log-events"
-connector_logs_topic = "hyperswitch-connector-api-events"
+connector_logs_topic = "hyperswitch-outgoing-connector-events"
 outgoing_webhook_logs_topic = "hyperswitch-outgoing-webhook-events"
 dispute_analytics_topic = "hyperswitch-dispute-events"
 audit_events_topic = "hyperswitch-audit-events"
diff --git a/crates/analytics/docs/clickhouse/scripts/authentications.sql b/crates/analytics/docs/clickhouse/scripts/authentications.sql
index 5876bee9f7..1eddcd03f0 100644
--- a/crates/analytics/docs/clickhouse/scripts/authentications.sql
+++ b/crates/analytics/docs/clickhouse/scripts/authentications.sql
@@ -58,7 +58,7 @@ CREATE TABLE authentication_queue (
     `issuer_id` Nullable(String),
     `scheme_name` Nullable(String),
     `exemption_requested` Nullable(Bool),
-    `exemption_accepted` Nullable(Bool),
+    `exemption_accepted` Nullable(Bool)
 ) ENGINE = Kafka SETTINGS kafka_broker_list = 'kafka0:29092',
 kafka_topic_list = 'hyperswitch-authentication-events',
 kafka_group_name = 'hyper',
@@ -196,7 +196,7 @@ CREATE MATERIALIZED VIEW authentication_mv TO authentications (
     `issuer_id` Nullable(String),
     `scheme_name` Nullable(String),
     `exemption_requested` Nullable(Bool),
-    `exemption_accepted` Nullable(Bool),
+    `exemption_accepted` Nullable(Bool)
 ) AS
 SELECT
     authentication_id,