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

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.

AuthorShruti Gupta[aut,cre]
Date of publication2015-04-13 16:40:13
MaintainerShruti Gupta<shruti.gupta@mu-sigma.com>
LicenseApache License 2.0 | file LICENSE
Version1.0

View on CRAN

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

Questions? Problems? Suggestions? or email at ian@mutexlabs.com.

Please suggest features or report bugs with the GitHub issue tracker.

All documentation is copyright its authors; we didn't write any of that.