rkafka.send: KAFKA producer sending message

Description Usage Arguments Value Author(s) Examples

Description

This function sends message to a particular name through a producer

Usage

1

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

1
2
3
4
5
## Not run: 
producer1=rkafka.createProducer("127.0.0.1:9092")
rkafka.send(producer1,"test","127.0.0.1:9092","Testing")

## End(Not run)

shrutigupta23/rkafka documentation built on May 29, 2019, 9:36 a.m.