chore(recordings): use cooperative-sticky rebalance strategy (#15260)

Revert "revert(recordings): use cooperative-sticky rebalance strategy (#15211)" This reverts commit a40f011.
PostHog · Apr 26, 2023 · 96fe16f · 96fe16f
1 parent b75d560
commit 96fe16f
Show file tree

Hide file tree

Showing 13 changed files with 456 additions and 72 deletions.
diff --git a/plugin-server/functional_tests/kafka.ts b/plugin-server/functional_tests/kafka.ts
@@ -1,6 +1,6 @@
 import { CompressionCodecs, CompressionTypes } from 'kafkajs'
 import SnappyCodec from 'kafkajs-snappy'
-import { HighLevelProducer } from 'node-rdkafka'
+import { HighLevelProducer } from 'node-rdkafka-acosom'
 
 import { defaultConfig } from '../src/config/config'
 

diff --git a/plugin-server/package.json b/plugin-server/package.json
@@ -70,7 +70,7 @@
         "lru-cache": "^6.0.0",
         "luxon": "^1.27.0",
         "node-fetch": "^2.6.1",
-        "node-rdkafka": "^2.15.0",
+        "node-rdkafka-acosom": "2.16.1",
         "node-schedule": "^2.1.0",
         "pg": "^8.6.0",
         "pino": "^8.6.0",