rkafka (version 1.1)

rkafka.send: 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

Examples

# NOT RUN {
producer1=rkafka.createProducer("127.0.0.1:9092")
rkafka.send(producer1,"test","127.0.0.1:9092","Testing")
# }