Kafka Plugin
Adds a streaming plugin via kafkajs. No streaming integration currently exists in the toolkit.
Potential methods to include:
produce -- publish a message to a topicconsume -- subscribe and consume messages from a topicdisconnect
Uses kafkajs which uses a binary TCP protocol -- not substitutable by the existing HTTP lib. Requires explicit disconnect() to close the client, consistent with the Redis and SQL plugin patterns.
Kafka Plugin
Adds a streaming plugin via
kafkajs. No streaming integration currently exists in the toolkit.Potential methods to include:
produce-- publish a message to a topicconsume-- subscribe and consume messages from a topicdisconnectUses
kafkajswhich uses a binary TCP protocol -- not substitutable by the existing HTTP lib. Requires explicitdisconnect()to close the client, consistent with the Redis and SQL plugin patterns.