Package net.bugreaper.modules.kafka.setup

Class KafkaProducerHelper

java.lang.Object

net.bugreaper.modules.kafka.setup.KafkaProducerHelper

public class KafkaProducerHelper
extends Object

Kafka producer helper responsible for sending messages to Kafka topics.

Constructor Summary

Constructors

Constructor	Description
KafkaProducerHelper(String bootStrapServer)

Method Summary

Modifier and Type	Method	Description
void	send(String topic, String message)
void	sending(String topic, org.apache.kafka.clients.producer.ProducerRecord<String,String> produceRecord)
void	sendWithKey(String topic, String key, String message)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

KafkaProducerHelper

public KafkaProducerHelper(String bootStrapServer)

Method Details

send

public void send(String topic,
 String message)

sendWithKey

public void sendWithKey(String topic,
 String key,
 String message)

sending

public void sending(String topic,
 org.apache.kafka.clients.producer.ProducerRecord<String,String> produceRecord)