BufferedProducerBuilder (client 0.17.1-SNAPSHOT API)

public interface BufferedProducerBuilder

A builder for BufferedProducers.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`BufferedProducerBuilder`	`batchSetting(BatchSetting batchSetting)`	BufferedProducer will buffer records for each shard as a batch to send to servers, so `BatchSetting` is to control the batch buffer.
`BufferedProducer`	`build()`
`BufferedProducerBuilder`	`compressionType(CompressionType compressionType)`	Set the compression type.
`BufferedProducerBuilder`	`flowControlSetting(FlowControlSetting flowControlSetting)`	`FlowControlSetting` is to control total records(including buffered batch records for all keys and sending records) through `BufferedProducer`.
`BufferedProducerBuilder`	`requestTimeoutMs(long timeoutMs)`
`BufferedProducerBuilder`	`stream(String streamName)`

- Method Detail
  - stream
```
BufferedProducerBuilder stream(String streamName)
```
  - batchSetting
```
BufferedProducerBuilder batchSetting(BatchSetting batchSetting)
```
    BufferedProducer will buffer records for each shard as a batch to send to servers, so BatchSetting is to control the batch buffer.
    
    Parameters:
    
    batchSetting - setting for batch buffer
    
    Returns:
    
    the BufferedProducerBuilder instance
  - flowControlSetting
```
BufferedProducerBuilder flowControlSetting(FlowControlSetting flowControlSetting)
```
    FlowControlSetting is to control total records(including buffered batch records for all keys and sending records) through BufferedProducer.
    
    Parameters:
    
    flowControlSetting - setting for flow control
    
    Returns:
    
    the BufferedProducerBuilder instance
  - compressionType
```
BufferedProducerBuilder compressionType(CompressionType compressionType)
```
    Set the compression type.
    
    Parameters:
    
    compressionType - type of compression
    
    Returns:
    
    the BufferedProducerBuilder instance
  - requestTimeoutMs
```
BufferedProducerBuilder requestTimeoutMs(long timeoutMs)
```
  - build
```
BufferedProducer build()
```