com.cloudera.oryx.api

Interface TopicProducer<K,M>

Type Parameters:

K - key type to send

M - message type to send

All Superinterfaces:

AutoCloseable, Closeable

All Known Implementing Classes:

TopicProducerImpl, TopicProducerImpl

public interface TopicProducer<K,M>
extends Closeable

Wraps access to a message topic Producer, including logic to instantiate the object. This is a wrapper that can be serialized and re-create the Producer remotely.

Since:

2.0.0

Method Summary

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

Method Detail

getUpdateBroker

String getUpdateBroker()

Returns:

broker(s) that the producer is sending to

Since:

2.0.0

getTopic

String getTopic()

Returns:

topic that the producer is sending to

Since:

2.0.0

send

void send(K key,
          M message)

Parameters:

key - key to send to the topic

message - message to send with key to the topic

Since:

2.0.0

close

default void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Since:

2.0.0