Class TopicProducer

java.lang.Object
com.infinyon.fluvio.TopicProducer

public final class TopicProducer extends Object

Sends records to a particular topic.

  • 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