rkafka.send: KAFKA producer sending message

View source: R/rkafka.R

rkafka.sendR 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)

rkafka documentation built on Aug. 10, 2022, 5:08 p.m.