graphql-kafkajs-subscriptions
                                
                                
                                
                                    graphql-kafkajs-subscriptions copied to clipboard
                            
                            
                            
                        Apollo graphql subscriptions using kafkajs
Bumps [semver-regex](https://github.com/sindresorhus/semver-regex) from 3.1.3 to 3.1.4. Release notes Sourced from semver-regex's releases. v3.1.4 Backport of ReDoS fix https://github.com/sindresorhus/semver-regex/commit/7712ba564d40da101cf2b2b33e6a910d9f2f57f4 Commits See full diff in compare view [](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will...
Bumps [trim-off-newlines](https://github.com/stevemao/trim-off-newlines) from 1.0.1 to 1.0.3. Commits c3b28d3 1.0.3 6226c95 Merge pull request #4 from Trott/fix-it-again c77691d fix: remediate ReDOS further 76ca93c chore: pin mocha to version that works with...
Bumps [minimist](https://github.com/substack/minimist) from 1.2.5 to 1.2.6. Commits 7efb22a 1.2.6 ef88b93 security notice for additional prototype pollution issue c2b9819 isConstructorOrProto adapted from PR bc8ecee test from prototype pollution PR See full...
I adapted the Apollo Group working sample, https://github.com/apollographql/docs-examples/blob/main/apollo-server/v3/subscriptions-graphql-ws/src/index.ts, to work with grapql-kafkajs-subscription and when I do that I receive an unexpected message on the subscribing client. When working with the...
1. unsubscribe didn't remove the index from the map 2. subscribe needed to create an array of all keys to get the next index 3. the map used arrays to...
We have an special case in which the channel is inside the payload and not on the headers. I think it will be nice to allow the user to chose...
feat: add consumerOn Closes Consumer inside KafkaPubSub class is private #26
The **consumer** inside the **KafkaPubSub** class is private. I need to access it in order to register it to some emitted events like "_consumer.stop_" or "_consumer.crash_". Can you please provide...
We release updates to our applications on a weekly basis, and with the forced random group id each time an application is deployed, we now have hundreds of unused consumer...
Bumps [braces](https://github.com/micromatch/braces) from 3.0.2 to 3.0.3. Commits 74b2db2 3.0.3 88f1429 update eslint. lint, fix unit tests. 415d660 Snyk js braces 6838727 (#40) 190510f fix tests, skip 1 test in test/braces.expand...