io.simplesource.saga.shared.kafka

Class KafkaPublisher<K,V>

java.lang.Object

io.simplesource.saga.shared.kafka.KafkaPublisher<K,V>

public final class KafkaPublisher<K,V>
extends Object

Constructor Summary

Constructors

Constructor and Description
KafkaPublisher(org.apache.kafka.clients.producer.KafkaProducer<byte[],byte[]> kafkaProducer, org.apache.kafka.common.serialization.Serde<K> keySerdes, org.apache.kafka.common.serialization.Serde<V> valueSerdes)

Method Summary

Modifier and Type	Method and Description
void	send(String topic, K key, V value)

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaPublisher

public KafkaPublisher(org.apache.kafka.clients.producer.KafkaProducer<byte[],byte[]> kafkaProducer,
                      org.apache.kafka.common.serialization.Serde<K> keySerdes,
                      org.apache.kafka.common.serialization.Serde<V> valueSerdes)

Method Detail

send

public void send(String topic,
                 K key,
                 V value)