public static class KafkaProperties.Consumer extends ObjectSE
コンストラクターと説明 |
---|
Consumer() |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
public KafkaProperties.Ssl getSsl()
public KafkaProperties.Security getSecurity()
public DurationSE getAutoCommitInterval()
public void setAutoCommitInterval(DurationSE autoCommitInterval)
public StringSE getAutoOffsetReset()
public void setAutoOffsetReset(StringSE autoOffsetReset)
public StringSE getClientId()
public void setClientId(StringSE clientId)
public BooleanSE getEnableAutoCommit()
public void setEnableAutoCommit(BooleanSE enableAutoCommit)
public DurationSE getFetchMaxWait()
public void setFetchMaxWait(DurationSE fetchMaxWait)
public DataSize getFetchMinSize()
public void setFetchMinSize(DataSize fetchMinSize)
public StringSE getGroupId()
public void setGroupId(StringSE groupId)
public DurationSE getHeartbeatInterval()
public void setHeartbeatInterval(DurationSE heartbeatInterval)
public KafkaProperties.IsolationLevel getIsolationLevel()
public void setIsolationLevel(KafkaProperties.IsolationLevel isolationLevel)
public ClassSE<?> getKeyDeserializer()
public void setKeyDeserializer(ClassSE<?> keyDeserializer)
public ClassSE<?> getValueDeserializer()
public void setValueDeserializer(ClassSE<?> valueDeserializer)
public IntegerSE getMaxPollRecords()
public void setMaxPollRecords(IntegerSE maxPollRecords)