yindo/posthog
1
0
Fork 0
mirror of https://github.com/BillyOutlast/posthog.git synced 2026-02-04 03:01:23 +01:00
Code Issues Packages Projects Releases Wiki Activity

feat(plugin-server): Add WARPSTREAM_PRODUCER kafka config target (#41194)

Browse Source
This commit is contained in:
José Sequeira
2025-11-10 14:46:39 +01:00
committed by GitHub
parent dc24573eb2
commit a298fae5df
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
plugin-server/src/kafka/config.ts
View File

@@ -10,7 +10,7 @@ export const RDKAFKA_LOG_LEVEL_MAPPING = {
ERROR: 3,
}
export type KafkaConfigTarget = 'PRODUCER' | 'CONSUMER' | 'CDP_PRODUCER'
export type KafkaConfigTarget = 'PRODUCER' | 'CONSUMER' | 'CDP_PRODUCER' | 'WARPSTREAM_PRODUCER'
export const getKafkaConfigFromEnv = (prefix: KafkaConfigTarget): GlobalConfig => {
// NOTE: We have learnt that having as much exposed config to the env as possible is really useful

2
plugin-server/src/main/ingestion-queues/session-recording-v2/consumer.ts
View File

@@ -299,7 +299,7 @@ export class SessionRecordingIngester {
// Initialize overflow producer if not consuming from overflow
if (!this.consumeOverflow) {
this.kafkaOverflowProducer = await KafkaProducerWrapper.create(this.hub, 'CONSUMER')
this.kafkaOverflowProducer = await KafkaProducerWrapper.create(this.hub, 'WARPSTREAM_PRODUCER')
}
// Initialize restriction handler with the overflow producer