Using Apache 'Kafka' Messaging Queue Through 'R'


[Up] [Top]

Documentation for package ‘rkafka’ version 1.3

Help Pages

autoCommitEnable Creating KAFKA consumer
autoCommitInterval Creating KAFKA consumer
autoOffsetReset Creating KAFKA consumer
batchNumMessages Creating KAFKA producer
clientId Creating simple KAFKA consumer
compressedTopics Creating KAFKA producer
compressionCodec Creating KAFKA producer
connectionTimeOut Creating simple KAFKA consumer
consumerTimeoutMs Creating KAFKA consumer
groupId Creating KAFKA consumer
ip KAFKA producer sending message
kafkaProducerBufferSize Creating simple KAFKA consumer
kafkaServerPort Creating simple KAFKA consumer
kafkaServerURL Creating simple KAFKA consumer
message KAFKA producer sending message
metadataBrokerList Creating KAFKA producer
msgReadSize KAKFA Simple Consumer receiving messages
Offset KAKFA Simple Consumer receiving messages
partition KAKFA Simple Consumer receiving messages
partitionerClass Creating KAFKA producer
producerType Creating KAFKA producer
queueBufferingMaxMessages Creating KAFKA producer
queueBufferingMaxTime Creating KAFKA producer
queueEnqueueTimeoutTime Creating KAFKA producer
rkafka Using Apache 'Kafka' Messaging Queue Through 'R'
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.read KAFKA consumer reading messages(single)
rkafka.readFromSimpleConsumer KAFKA Simple Consumer Reading
rkafka.readPoll KAFKA consumer reading messages(batch)
rkafka.receiveFromSimpleConsumer KAKFA Simple Consumer receiving messages
rkafka.send KAFKA producer sending message
serializerClass Creating KAFKA producer
SimpleConsumer Closing KAKFA Simple consumer
SimpleConsumerObj KAFKA Simple Consumer Reading
topicName KAFKA producer sending message
zookeeperConnect Creating KAFKA consumer
zookeeperConnectionTimeoutMs Creating KAFKA consumer