Last data update: 2014.03.03
|
R: KAFKA producer sending message
rkafka.send | R Documentation |
KAFKA producer sending message
Description
This function sends message to a particular name through a producer
Usage
rkafka.send(producer, topicName, ip, message)
Arguments
producer |
Producer through which messages are to be sent
Required:Mandatory
Type:String
|
topicName |
Topic to which messages are to be sent. If topicName doesn't exist, new topic is created
Required:Mandatory
Type:String
|
ip |
ip on which producer is running
Required:Mandatory
Type:String
|
message |
message to be sent
Required:Mandatory
Type:String
|
Value
Doesn't return a value
Author(s)
Shruti Gupta
Examples
## Not run:
producer1=rkafka.createProducer("127.0.0.1:9092")
rkafka.send(producer1,"test","127.0.0.1:9092","Testing")
## End(Not run)
Results
|