rca-graphql-kafka-subscriptions
v0.2.2
Published
Apollo graphql subscription over Kafka protocol
Downloads
9
Maintainers
Readme
graphql-kafka-subscriptions
Apollo graphql subscriptions over Kafka protocol
One producer and one consumer for each node instance. Communication happens over a single kafka topic.
Installation
npm install graphql-kafka-subscriptions
Usage
import { KafkaPubSub } from 'graphql-kafka-subscriptions'
export const pubsub = new KafkaPubSub({
topic: 'anything',
host: 'INSERT_KAFKA_IP',
port: 'INSERT_KAFKA_PORT',
})
// as mentioned in the comments of https://github.com/ancashoria/graphql-kafka-subscriptions/issues/4
// you will need to upate the site calls of `publish` in your application as called out below.
// the stock PubSub::publish expects a string and an object
pubsub.publish('messageAdded', {
messageAdded: newMessage,
channelId: message.channelId
});
// KafkaPubSub::publish expects the first parameter to be inserted into the object
pubsub.publish({
channel: 'messageAdded',
messageAdded: newMessage,
channelId: message.channelId
});
Special thanks to:
- davidyaha for graphql-redis-subscriptions which was the main inspiration point for this project
- Apollo graphql community
Help greatly appreciated