R Graphical Manual

Last data update: 2014.03.03

Data Source

R Release (3.2.3)
CranContrib
BioConductor
All

Data Type

Packages
Functions
Images
Data set

Classification

Results 1 - 10 of 12 found.
[1] < 1 2 > [2] Sort:

rkafka.closeProducer (Package: rkafka) :

This function closes the KAFKA producer

● Data Source: CranContrib
● Keywords: ~close, ~kafka, ~producer
● Alias: rkafka.closeProducer
● 0 images

rkafka.send (Package: rkafka) :

This function sends message to a particular name through a producer

● Data Source: CranContrib
● Keywords: ~KAFKA, ~Message sending, ~Producer
● Alias: rkafka.send
● 0 images

rkafka.closeConsumer (Package: rkafka) :

This functions shuts down the KAFKA consumer

● Data Source: CranContrib
● Keywords: ~close, ~consumer, ~kafka
● Alias: rkafka.closeConsumer
● 0 images

rkafka (Package: rkafka) :

It provides functionalities of creating a 'Kafka' producer, simple consumer,high level consumer and sending and receiving messages.

● Data Source: CranContrib
● Keywords: Apache Kafka
● Alias: rkafka
● 0 images

rkafka.createConsumer (Package: rkafka) :

This function creates a KAFKA consumer

● Data Source: CranContrib
● Keywords: ~consumer, ~kafka
● Alias: rkafka.createConsumer, zookeeperConnect
● 0 images

rkafka.receiveFromSimpleConsumer (Package: rkafka) :

This function allows the KAKFA Simple Consumer to receive messages from a particular topic. However, this doesn't display the messages. To read the messages, use the rkafka.readFromSimpleConsumer function.

● Data Source: CranContrib
● Keywords: ~consumer, ~kafka, ~simple
● Alias: rkafka.receiveFromSimpleConsumer
● 0 images

rkafka.createProducer (Package: rkafka) :

This function is used to create a KAFKA producer

● Data Source: CranContrib
● Keywords: ~KAFKA, ~producer
● Alias: batchNumMessages, compressedTopics, compressionCodec, metadataBrokerList, partitionerClass, producerType, queueBufferingMaxMessages, queueBufferingMaxTime, queueEnqueueTimeoutTime, rkafka.createProducer, serializerClass
● 0 images

rkafka.readFromSimpleConsumer (Package: rkafka) :

This function returns one message at a time which are read by a KAFKA Simple Consumer

● Data Source: CranContrib
● Keywords: ~consumer, ~kafka, ~read, ~simple
● Alias: SimpleConsumerObj, rkafka.readFromSimpleConsumer
● 0 images

rkafka.closeSimpleConsumer (Package: rkafka) :

This functions shuts down the KAFKA Simple consumer

● Data Source: CranContrib
● Keywords: ~close, ~consumer, ~kafka, ~simple
● Alias: SimpleConsumer, rkafka.closeSimpleConsumer
● 0 images

rkafka.createSimpleConsumer (Package: rkafka) :

This function creates the Simple Consumer

● Data Source: CranContrib
● Keywords: ~consumer, ~create, ~kafka, ~simple
● Alias: clientId, connectionTimeOut, kafkaProducerBufferSize, kafkaServerPort, kafkaServerURL, rkafka.createSimpleConsumer
● 0 images