rkafka: Using Apache 'Kafka' Messaging Queue Through 'R'

Share:

Apache 'Kafka' is an open-source message broker project developed by the Apache Software Foundation which can be thought of as a distributed, partitioned, replicated commit log service.At a high level, producers send messages over the network to the 'Kafka' cluster which in turn serves them up to consumers.See <http://kafka.apache.org/> for more information.Functions included in this package enable:1.Creating 'Kafka' producer 2.Writing messages to a topic 3.Closing 'Kafka' producer 4.Creating 'Kafka' consumer 5.Reading messages from a topic 6.Closing 'Kafka' consumer. The jars required for this package are included in a separate package 'rkafkajars'.Thanks to Mu Sigma for their continued support throughout the development of the package.

Author
Shruti Gupta[aut,cre]
Date of publication
2015-04-13 16:40:13
Maintainer
Shruti Gupta<shruti.gupta@mu-sigma.com>
License
Apache License 2.0 | file LICENSE
Version
1.0

View on CRAN

Man pages

rakfa.receiveFromSimpleConsumer
KAKFA Simple Consumer receiving messages
rkafka.closeConsumer
Closing KAKFA consumer
rkafka.closeProducer
KAFKA producer shutdown
rkafka.closeSimpleConsumer
Closing KAKFA Simple consumer
rkafka.createConsumer
Creating KAFKA consumer
rkafka.createProducer
Creating KAFKA producer
rkafka.createSimpleConsumer
Creating simple KAFKA consumer
rkafka-package
Using Apache 'Kafka' Messaging Queue Through 'R'
rkafka.read
KAFKA consumer reading messages(single)
rkafka.readFromSimpleConsumer
KAFKA Simple Consumer Reading
rkafka.readPoll
KAFKA consumer reading messages(batch)
rkafka.send
KAFKA producer sending message

Files in this package

rkafka
rkafka/inst
rkafka/inst/doc
rkafka/inst/doc/rkafka.Rnw
rkafka/inst/doc/rkafka.pdf
rkafka/inst/doc/rkafka-manual.pdf
rkafka/inst/NOTICE
rkafka/tests
rkafka/tests/unitTests.R
rkafka/NAMESPACE
rkafka/R
rkafka/R/rkafka.R
rkafka/vignettes
rkafka/vignettes/MuSigmaLogoText.jpg
rkafka/vignettes/rkafka.Rnw
rkafka/vignettes/producer_consumer.png
rkafka/vignettes/MuSigmaLogo.jpg
rkafka/vignettes/MuSigma.jpg
rkafka/MD5
rkafka/build
rkafka/build/vignette.rds
rkafka/DESCRIPTION
rkafka/man
rkafka/man/rkafka.closeProducer.Rd
rkafka/man/rkafka.send.Rd
rkafka/man/rkafka.closeConsumer.Rd
rkafka/man/rkafka-package.Rd
rkafka/man/rkafka.createConsumer.Rd
rkafka/man/rakfa.receiveFromSimpleConsumer.Rd
rkafka/man/rkafka.createProducer.Rd
rkafka/man/rkafka.readFromSimpleConsumer.Rd
rkafka/man/rkafka.closeSimpleConsumer.Rd
rkafka/man/rkafka.createSimpleConsumer.Rd
rkafka/man/rkafka.read.Rd
rkafka/man/rkafka.readPoll.Rd
rkafka/LICENSE