Registry / messaging / poseidon-cluster

poseidon-cluster

JSON →

library0.3.3rbrubygemsunverified

Cluster extensions for Poseidon, a producer and consumer implementation for Kafka >= 0.8.

messaging networking

gem install poseidon_cluster

github ↗homepage ↗docs ↗

INSTALL

IMPORT

SIG · POSEIDON-CLUSTER

poseidon-cluster

messagingrubyv0.3.3

harness data pending

Install & Compatibility

Where this runs

No compatibility data collected yet for this library.

Code

Verified usage

Verified import paths — ran on the pinned version, not inferred.

PoseidonCluster

✓ require 'poseidon_cluster'

Consume messages from a Kafka topic

require 'poseidon_cluster' consumer = Poseidon::Cluster::Consumer.new( 'my_group', ['localhost:9092'], ['my_topic'] ) consumer.each do |message| puts message.value end

Debug

Known issues

breakingRequires Kafka >= 0.8

fix

Ensure your Kafka cluster version is 0.8 or higher.

affects: >= 0.3.0

Upgrade

Version history

0.3.3latest on RubyGems

Audit

Dependencies

No dependency data recorded yet.

Agent activity

16 hits · last 30 days

node

Amazon

OpenAI (training)

Resources

githubhttps://github.com/bsm/poseidon_cluster ↗

homepagehttps://github.com/bsm/poseidon_cluster ↗

docshttp://www.rubydoc.info/gems/poseidon_cluster/ ↗