Class KafkaProperties.Producer

Constructor Detail

• Producer

  public Producer()

Method Detail

• getSsl

  public KafkaProperties.Ssl getSsl()

• getAcks

  public String getAcks()

• setAcks

  public void setAcks​(String acks)

• getBatchSize

  public Integer getBatchSize()

• setBatchSize

  public void setBatchSize​(Integer batchSize)

• getBootstrapServers

  public List<String> getBootstrapServers()

• setBootstrapServers

  public void setBootstrapServers​(List<String> bootstrapServers)

• getBufferMemory

  public Long getBufferMemory()

• setBufferMemory

  public void setBufferMemory​(Long bufferMemory)

• getClientId

  public String getClientId()

• setClientId

  public void setClientId​(String clientId)

• getCompressionType

  public String getCompressionType()

• setCompressionType

  public void setCompressionType​(String compressionType)

• getKeySerializer

  public Class<?> getKeySerializer()

• setKeySerializer

  public void setKeySerializer​(Class<?> keySerializer)

• getValueSerializer

  public Class<?> getValueSerializer()

• setValueSerializer

  public void setValueSerializer​(Class<?> valueSerializer)

• getRetries

  public Integer getRetries()

• setRetries

  public void setRetries​(Integer retries)

• buildProperties

  public Map<String,​Object> buildProperties()