OnlineVeniceProducer (venice API)

java.lang.Object
- com.linkedin.venice.producer.AbstractVeniceProducer<K,V>
- - com.linkedin.venice.producer.online.OnlineVeniceProducer<K,V>

All Implemented Interfaces:

VeniceProducer<K,V>, java.io.Closeable, java.lang.AutoCloseable
```
public class OnlineVeniceProducer<K,V>
extends AbstractVeniceProducer<K,V>
```
An implementation of a VeniceProducer suitable for online applications. This producer only supports producing data to a store's RT topic.

See Also:

AbstractVeniceProducer, VeniceProducer

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`close()`
`protected VersionCreationResponse`	`requestTopic()`	This function should return a `VersionCreationResponse` to determine the PubSub topic and the characteristics that the producer should follow.

Methods inherited from class com.linkedin.venice.producer.AbstractVeniceProducer
asyncDelete, asyncDelete, asyncPut, asyncPut, asyncUpdate, asyncUpdate, configure, constructVeniceWriter, getSerializer, isClosed

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Method Detail
  - requestTopic
```
protected VersionCreationResponse requestTopic()
```
    Description copied from class: AbstractVeniceProducer
    
    This function should return a VersionCreationResponse to determine the PubSub topic and the characteristics that the producer should follow.
    
    Specified by:
    
    requestTopic in class AbstractVeniceProducer<K,V>
  - close
```
public void close()
           throws java.io.IOException
```
    Specified by:
    
    close in interface java.lang.AutoCloseable
    
    Specified by:
    
    close in interface java.io.Closeable
    
    Overrides:
    
    close in class AbstractVeniceProducer<K,V>
    
    Throws:
    
    java.io.IOException