クラス KafkaProperties.Producer

java.lang.ObjectSE
org.springframework.boot.autoconfigure.kafka.KafkaProperties.Producer
含まれているクラス:
KafkaProperties

public static class KafkaProperties.Producer extends ObjectSE
  • コンストラクターの詳細

    • Producer

      public Producer()
  • メソッドの詳細

    • getSsl

      public KafkaProperties.Ssl getSsl()
    • getSecurity

      public KafkaProperties.Security getSecurity()
    • getAcks

      public StringSE getAcks()
    • setAcks

      public void setAcks(StringSE acks)
    • getBatchSize

      public DataSize getBatchSize()
    • setBatchSize

      public void setBatchSize(DataSize batchSize)
    • getBootstrapServers

      public ListSE<StringSE> getBootstrapServers()
    • setBootstrapServers

      public void setBootstrapServers(ListSE<StringSE> bootstrapServers)
    • getBufferMemory

      public DataSize getBufferMemory()
    • setBufferMemory

      public void setBufferMemory(DataSize bufferMemory)
    • getClientId

      public StringSE getClientId()
    • setClientId

      public void setClientId(StringSE clientId)
    • getCompressionType

      public StringSE getCompressionType()
    • setCompressionType

      public void setCompressionType(StringSE compressionType)
    • getKeySerializer

      public ClassSE<?> getKeySerializer()
    • setKeySerializer

      public void setKeySerializer(ClassSE<?> keySerializer)
    • getValueSerializer

      public ClassSE<?> getValueSerializer()
    • setValueSerializer

      public void setValueSerializer(ClassSE<?> valueSerializer)
    • getRetries

      public IntegerSE getRetries()
    • setRetries

      public void setRetries(IntegerSE retries)
    • getTransactionIdPrefix

      public StringSE getTransactionIdPrefix()
    • setTransactionIdPrefix

      public void setTransactionIdPrefix(StringSE transactionIdPrefix)
    • getProperties

      public MapSE<StringSE,StringSE> getProperties()
    • buildProperties

      public MapSE<StringSE,ObjectSE> buildProperties()