Learn R Programming

rkafka (version 1.4)

Using Apache 'Kafka' Messaging Queue Through 'R'

Description

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

Copy Link

Version

Install

install.packages('rkafka')

Monthly Downloads

112

Version

1.4

License

Apache License 2.0 | file LICENSE

Maintainer

Last Published

August 10th, 2022

Functions in rkafka (1.4)

rkafka.readPoll

KAFKA consumer reading messages(batch)
rkafka.closeSimpleConsumer

Closing KAKFA Simple consumer
rkafka.send

KAFKA producer sending message
rkafka.createConsumer

Creating KAFKA consumer
rkafka.readFromSimpleConsumer

KAFKA Simple Consumer Reading
rkafka.receiveFromSimpleConsumer

KAKFA Simple Consumer receiving messages
rkafka.closeConsumer

Closing KAKFA consumer
rkafka.createProducer

Creating KAFKA producer
rkafka.createSimpleConsumer

Creating simple KAFKA consumer
rkafka.read

KAFKA consumer reading messages(single)
rkafka

Using Apache 'Kafka' Messaging Queue Through 'R'
rkafka.closeProducer

KAFKA producer shutdown