public static class KafkaProperties.Producer extends ObjectSE
コンストラクターと説明 |
---|
Producer() |
修飾子と型 | メソッドと説明 |
---|---|
MapSE<StringSE, ObjectSE> | buildProperties() |
StringSE | getAcks() |
DataSize | getBatchSize() |
ListSE<StringSE> | getBootstrapServers() |
DataSize | getBufferMemory() |
StringSE | getClientId() |
StringSE | getCompressionType() |
ClassSE<?> | getKeySerializer() |
MapSE<StringSE, StringSE> | getProperties() |
IntegerSE | getRetries() |
KafkaProperties.Security | getSecurity() |
KafkaProperties.Ssl | getSsl() |
StringSE | getTransactionIdPrefix() |
ClassSE<?> | getValueSerializer() |
void | setAcks(StringSE acks) |
void | setBatchSize(DataSize batchSize) |
void | setBootstrapServers(ListSE<StringSE> bootstrapServers) |
void | setBufferMemory(DataSize bufferMemory) |
void | setClientId(StringSE clientId) |
void | setCompressionType(StringSE compressionType) |
void | setKeySerializer(ClassSE<?> keySerializer) |
void | setRetries(IntegerSE retries) |
void | setTransactionIdPrefix(StringSE transactionIdPrefix) |
void | setValueSerializer(ClassSE<?> valueSerializer) |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
public KafkaProperties.Ssl getSsl()
public KafkaProperties.Security getSecurity()
public StringSE getAcks()
public void setAcks(StringSE acks)
public DataSize getBatchSize()
public void setBatchSize(DataSize batchSize)
public DataSize getBufferMemory()
public void setBufferMemory(DataSize bufferMemory)
public StringSE getClientId()
public void setClientId(StringSE clientId)
public StringSE getCompressionType()
public void setCompressionType(StringSE compressionType)
public ClassSE<?> getKeySerializer()
public void setKeySerializer(ClassSE<?> keySerializer)
public ClassSE<?> getValueSerializer()
public void setValueSerializer(ClassSE<?> valueSerializer)
public IntegerSE getRetries()
public void setRetries(IntegerSE retries)
public StringSE getTransactionIdPrefix()
public void setTransactionIdPrefix(StringSE transactionIdPrefix)