程序包 org.springframework.boot.autoconfigure.kafka

类 KafkaProperties.Producer

java.lang.Object
org.springframework.boot.autoconfigure.kafka.KafkaProperties.Producer
封闭类:
KafkaProperties
public static class KafkaProperties.Producer extends Object

  • 构造器详细资料

    • Producer

      public Producer()

  • 方法详细资料

    • 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)