Page Menu
Home
Software Heritage
Search
Configure Global Search
Log In
Files
F9345253
README.md
No One
Temporary
Actions
Download File
Edit File
Delete File
View Transforms
Subscribe
Mute Notifications
Award Token
Flag For Later
Size
1 KB
Subscribers
None
README.md
View Options
#
kafka
-
rb
kafka
-
rb
allows
you
to
produce
messages
to
the
Kafka
distributed
publish
/
subscribe
messaging
service
.
##
Requirements
You
need
to
have
access
to
your
Kafka
instance
and
be
able
to
connect
through
TCP
.
You
can
obtain
a
copy
and
instructions
on
how
to
setup
kafka
at
https
:
//github.com/kafka-dev/kafka
##
Installation
sudo
gem
install
kafka
-
rb
(
the
code
works
fine
with
JRuby
,
Ruby
1.8
x
and
Ruby
1.9
.
x
)
##
Usage
###
Sending
a
simple
message
require
'
kafka
'
producer
=
Kafka
::
Producer
.
new
message
=
Kafka
::
Message
.
new
(
"some random message content"
)
producer
.
send
(
message
)
###
Sending
a
sequence
of
messages
require
'
kafka
'
producer
=
Kafka
::
Producer
.
new
message1
=
Kafka
::
Message
.
new
(
"some random message content"
)
message2
=
Kafka
::
Message
.
new
(
"some more content"
)
producer
.
send
([
message1
,
message2
])
###
Batching
a
bunch
of
messages
using
the
block
syntax
require
'
kafka
'
producer
=
Kafka
::
Producer
.
new
producer
.
batch
do
|
messages
|
puts
"Batching a send of multiple messages.."
messages
<<
Kafka
::
Message
.
new
(
"first message to send"
)
messages
<<
Kafka
::
Message
.
new
(
"second message to send"
)
end
*
they
will
be
sent
all
at
once
,
after
the
block
execution
###
Consuming
messages
one
by
one
require
'
kafka
'
consumer
=
Kafka
::
Consumer
.
new
messages
=
consumer
.
consume
###
Consuming
messages
using
a
block
loop
require
'
kafka
'
consumer
=
Kafka
::
Consumer
.
new
consumer
.
loop
do
|
messages
|
puts
"Received"
puts
messages
end
Contact
for
questions
alejandrocrosa
at
(@)
gmail
.
com
http
:
//twitter.com/alejandrocrosa
File Metadata
Details
Attached
Mime Type
text/x-ruby
Expires
Fri, Jul 4, 3:15 PM (4 d, 22 h ago)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
3288311
Attached To
rPKAFKA Kafka Debian packaging
Event Timeline
Log In to Comment