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

Functions

autoCommitEnable Man page
autoCommitInterval Man page
autoOffsetReset Man page
batchNumMessages Man page
clientId Man page
compressedTopics Man page
compressionCodec Man page
connectionTimeOut Man page
consumerTimeoutMs Man page
groupId Man page
ip Man page
kafkaProducerBufferSize Man page
kafkaServerPort Man page
kafkaServerURL Man page
message Man page
metadataBrokerList Man page
msgReadSize Man page
Offset Man page
partition Man page
partitionerClass Man page
producer Man page
producer Man page
producerType Man page
queueBufferingMaxMessages Man page
queueBufferingMaxTime Man page
queueEnqueueTimeoutTime Man page
rkafka Man page
rkafka.closeConsumer Man page
rkafka.closeProducer Man page
rkafka.closeSimpleConsumer Man page
rkafka.createConsumer Man page
rkafka.createProducer Man page
rkafka.createSimpleConsumer Man page
rkafka.read Man page
rkafka.readFromSimpleConsumer Man page
rkafka.readPoll Man page
rkafka.receiveFromSimpleConsumer Man page
rkafka.send Man page
serializerClass Man page
SimpleConsumer Man page
SimpleConsumerObj Man page
SimpleConsumerObj Man page
topicName Man page
topicName Man page
topicName Man page
zookeeperConnect Man page
zookeeperConnectionTimeoutMs Man page

Files

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.