com.cloudera.oryx.lambda

Class TopicProducerImpl<K,M>

java.lang.Object

com.cloudera.oryx.lambda.TopicProducerImpl<K,M>

Type Parameters:

K - key type to send

M - message type to send

All Implemented Interfaces:

TopicProducer<K,M>, Closeable, AutoCloseable

public final class TopicProducerImpl<K,M>
extends Object
implements TopicProducer<K,M>

Wraps access to a Kafka message topic Producer.

Constructor Summary

Constructors

Constructor and Description
TopicProducerImpl(String updateBroker, String topic, boolean async)

Method Summary

Modifier and Type	Method and Description
void	close()
String	getTopic()
String	getUpdateBroker()
void	send(K key, M message)

Methods inherited from class java.lang.Object

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

Constructor Detail

TopicProducerImpl

public TopicProducerImpl(String updateBroker,
                         String topic,
                         boolean async)

Method Detail

getUpdateBroker

public String getUpdateBroker()

Specified by:

getUpdateBroker in interface TopicProducer<K,M>

Returns:

broker(s) that the producer is sending to

getTopic

public String getTopic()

Specified by:

getTopic in interface TopicProducer<K,M>

Returns:

topic that the producer is sending to

send

public void send(K key,
                 M message)

Specified by:

send in interface TopicProducer<K,M>

Parameters:

key - key to send to the topic

message - message to send with key to the topic

close

public void close()

Specified by:

close in interface TopicProducer<K,M>

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable