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.

Documentation

Manual: rkafka.pdf
Vignette: rkafka

Maintainer: Shruti Gupta<shruti.gupta at mu-sigma.com>

Author(s): Shruti Gupta[aut,cre]">*

Install package and any missing dependencies by running this line in your R console:

install.packages("rkafka")

Depends rJava, RUnit, rkafkajars
Imports
Suggests
Enhances
Linking to
Reverse
depends
Reverse
imports
Reverse
suggests
Reverse
enhances
Reverse
linking to

Package rkafka
Materials
URL
Task Views
Version 1.0
Published 2015-04-13
License Apache License 2.0 | file LICENSE
BugReports
SystemRequirements Oracle Java 7,Apache Kafka 2.8.0-0.8.1.1
NeedsCompilation no
Citation
CRAN checks rkafka check results
Package source rkafka_1.0.tar.gz