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.
|Date of publication||2015-04-13 16:40:13|
|License||Apache License 2.0 | file LICENSE|
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