コンストラクターの詳細

• Producer

  public Producer()

メソッドの詳細

• getSsl

  public KafkaProperties.Ssl getSsl()

• getAcks

  public StringSE getAcks()

• setAcks

  public void setAcks(StringSE acks)

• getBatchSize

  public org.springframework.util.unit.DataSize getBatchSize()

• setBatchSize

  public void setBatchSize(org.springframework.util.unit.DataSize batchSize)

• getBootstrapServers

  public ListSE<StringSE> getBootstrapServers()

• setBootstrapServers

  public void setBootstrapServers(ListSE<StringSE> bootstrapServers)

• getBufferMemory

  public org.springframework.util.unit.DataSize getBufferMemory()

• setBufferMemory

  public void setBufferMemory(org.springframework.util.unit.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()