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

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 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.

Browse man pages Browse package API and functions Browse package files

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
Package repositoryView on CRAN
InstallationInstall the latest version of this package by entering the following in R:
install.packages("rkafka")

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

Functions

Offset Man page
SimpleConsumer Man page
SimpleConsumerObj Man page Man page
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
onLoad Source code
partition Man page
partitionerClass Man page
producer Man page Man page
producerType Man page
queueBufferingMaxMessages Man page
queueBufferingMaxTime Man page
queueEnqueueTimeoutTime Man page
rkafka Man page
rkafka.closeConsumer Man page Source code
rkafka.closeProducer Man page Source code
rkafka.closeSimpleConsumer Man page Source code
rkafka.createConsumer Man page Source code
rkafka.createProducer Man page Source code
rkafka.createSimpleConsumer Man page Source code
rkafka.read Man page Source code
rkafka.readFromSimpleConsumer Man page Source code
rkafka.readPoll Man page Source code
rkafka.receiveFromSimpleConsumer Man page Source code
rkafka.send Man page Source code
serializerClass Man page
topicName Man page Man page Man page
zookeeperConnect Man page
zookeeperConnectionTimeoutMs Man page

Files

inst
inst/doc
inst/doc/rkafka.Rnw
inst/doc/rkafka.pdf
inst/doc/rkafka-manual.pdf
inst/NOTICE
tests
tests/unitTests.R
NAMESPACE
R
R/rkafka.R
vignettes
vignettes/MuSigmaLogoText.jpg
vignettes/rkafka.Rnw
vignettes/producer_consumer.png
vignettes/MuSigmaLogo.jpg
vignettes/MuSigma.jpg
MD5
build
build/vignette.rds
DESCRIPTION
man
man/rkafka.closeProducer.Rd
man/rkafka.send.Rd
man/rkafka.closeConsumer.Rd
man/rkafka-package.Rd
man/rkafka.createConsumer.Rd
man/rakfa.receiveFromSimpleConsumer.Rd
man/rkafka.createProducer.Rd
man/rkafka.readFromSimpleConsumer.Rd
man/rkafka.closeSimpleConsumer.Rd
man/rkafka.createSimpleConsumer.Rd
man/rkafka.read.Rd
man/rkafka.readPoll.Rd
LICENSE
rkafka documentation built on May 19, 2017, 6:42 p.m.