Merge pull request #32 from jembi/clickhouse-password

Add ability to set clickhouse password
jembi · Sep 13, 2024 · c2213d6 · c2213d6
2 parents 2f2c6ce + a9777eb
commit c2213d6
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/apps/kafka-mapper-consumer/src/clickhouse/utils.ts b/apps/kafka-mapper-consumer/src/clickhouse/utils.ts
@@ -3,11 +3,16 @@ import {Table} from '../../src/types'
 
 const CLICKHOUSE_HOST = process.env.CLICKHOUSE_HOST ?? 'localhost'
 const CLICKHOUSE_PORT = parseInt(process.env.CLICKHOUSE_PORT ?? '8124')
+const CLICKHOUSE_PASSWORD = process.env.CLICKHOUSE_PASSWORD ?? ''
 
 const clickhouse = new ClickHouse({
   url: CLICKHOUSE_HOST,
   port: CLICKHOUSE_PORT,
-  debug: true
+  debug: true,
+  basicAuth: {
+    username: 'default',
+    password: CLICKHOUSE_PASSWORD
+  }
 })
 
 const selectQuery = (table: Table) =>