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 <https://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'.
Version: |
1.4 |
Depends: |
rJava, RUnit, rkafkajars |
Published: |
2022-08-10 |
Author: |
Shruti Gupta[aut,cre] |
Maintainer: |
Shruti Gupta <shrutigupta34 at gmail.com> |
License: |
Apache License 2.0 | file LICENSE |
NeedsCompilation: |
no |
SystemRequirements: |
Java JDK 1.7 or higher,Apache Kafka 2.8.0-0.8.1.1 |
CRAN checks: |
rkafka results |
Documentation:
Downloads:
Linking:
Please use the canonical form
https://CRAN.R-project.org/package=rkafka
to link to this page.