KafkaProducer: Creates KafkaProducer object (R6 class)

In dselivanov/rscalaKafka: Apache Kafka Client with rscala

Description

Creates KafkaProducer object (R6 class)

Usage

KafkaProducer

Format

An object of class R6ClassGenerator of length 24.

Usage

For usage details see Methods, Arguments and Examples sections.

producer$send(messages)

Methods

producer = KafkaProducer$new(broker_list, client_id = "RscalaKafkaClient", config = list())

Creares instance of KafkaProducer

producer$send(messages)

Asynchronously send a record to a topic.

Arguments

producer

A KafkaProducer object

client_id

string, identifier of the client

topic

name of a Kafka topic to send messages

broker_list

broker list for a Kafka cluster

config

ProducerConfig parameters (in key = value format) for kafka client - see them here https://kafka.apache.org/0100/javadoc/index.html?org/apache/kafka/clients/producer/ProducerConfig.html

messages

character strings - messages to send to kafka

dselivanov/rscalaKafka documentation built on May 15, 2019, 2:59 p.m.