Class KafkaProperties.Producer

java.lang.Object
org.springframework.boot.autoconfigure.kafka.KafkaProperties.Producer
Enclosing class:
KafkaProperties

public static class KafkaProperties.Producer extends Object
  • Constructor Details

    • Producer

      public Producer()
  • Method Details

    • getSsl

      public KafkaProperties.Ssl getSsl()
    • getSecurity

      public KafkaProperties.Security getSecurity()
    • getAcks

      public String getAcks()
    • setAcks

      public void setAcks(String acks)
    • getBatchSize

      public DataSize getBatchSize()
    • setBatchSize

      public void setBatchSize(DataSize batchSize)
    • getBootstrapServers

      public List<String> getBootstrapServers()
    • setBootstrapServers

      public void setBootstrapServers(List<String> bootstrapServers)
    • getBufferMemory

      public DataSize getBufferMemory()
    • setBufferMemory

      public void setBufferMemory(DataSize 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)
    • getTransactionIdPrefix

      public String getTransactionIdPrefix()
    • setTransactionIdPrefix

      public void setTransactionIdPrefix(String transactionIdPrefix)
    • getProperties

      public Map<String,String> getProperties()
    • buildProperties

      public Map<String,Object> buildProperties(SslBundles sslBundles)