Package com.infinyon.fluvio

Class TopicProducer

java.lang.Object

com.infinyon.fluvio.TopicProducer

public final class TopicProducer
extends Object

Sends records to a particular topic.

Method Summary

Modifier and Type	Method	Description
void	delete()
protected void	finalize()
final void	flush()
final void	send(byte[] key, byte[] value)	Send a key/value record to this topic.

Methods inherited from class java.lang.Object

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

Method Details

send

public final void send(byte[] key,
 byte[] value)
                throws Exception

Send a key/value record to this topic.

Throws:

Exception

flush

public final void flush()
                 throws Exception

Throws:

Exception

delete

public void delete()

finalize

protected void finalize()
                 throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable