public static class KafkaProperties.Listener extends ObjectSE
修飾子と型 | クラスと説明 |
---|---|
static class | KafkaProperties.Listener.Type |
コンストラクターと説明 |
---|
Listener() |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
public KafkaProperties.Listener.Type getType()
public void setType(KafkaProperties.Listener.Type type)
public org.springframework.kafka.listener.ContainerProperties.AckMode getAckMode()
public void setAckMode(org.springframework.kafka.listener.ContainerProperties.AckMode ackMode)
public StringSE getClientId()
public void setClientId(StringSE clientId)
public IntegerSE getConcurrency()
public void setConcurrency(IntegerSE concurrency)
public DurationSE getPollTimeout()
public void setPollTimeout(DurationSE pollTimeout)
public FloatSE getNoPollThreshold()
public void setNoPollThreshold(FloatSE noPollThreshold)
public IntegerSE getAckCount()
public void setAckCount(IntegerSE ackCount)
public DurationSE getAckTime()
public void setAckTime(DurationSE ackTime)
public DurationSE getIdleBetweenPolls()
public void setIdleBetweenPolls(DurationSE idleBetweenPolls)
public DurationSE getIdleEventInterval()
public void setIdleEventInterval(DurationSE idleEventInterval)
public DurationSE getIdlePartitionEventInterval()
public void setIdlePartitionEventInterval(DurationSE idlePartitionEventInterval)
public DurationSE getMonitorInterval()
public void setMonitorInterval(DurationSE monitorInterval)
public BooleanSE getLogContainerConfig()
public void setLogContainerConfig(BooleanSE logContainerConfig)
@DeprecatedSE @DeprecatedConfigurationProperty(reason="Use KafkaUtils#setConsumerRecordFormatter instead.") public boolean isOnlyLogRecordMetadata()
@DeprecatedSE public void setOnlyLogRecordMetadata(boolean onlyLogRecordMetadata)
public boolean isMissingTopicsFatal()
public void setMissingTopicsFatal(boolean missingTopicsFatal)
public boolean isImmediateStop()
public void setImmediateStop(boolean immediateStop)