public static class KafkaProperties.Listener extends Object
Modifier and Type | Class and Description |
---|---|
static class |
KafkaProperties.Listener.Type |
Constructor and Description |
---|
Listener() |
Modifier and Type | Method and Description |
---|---|
Integer |
getAckCount() |
org.springframework.kafka.listener.AbstractMessageListenerContainer.AckMode |
getAckMode() |
Duration |
getAckTime() |
Integer |
getConcurrency() |
Duration |
getPollTimeout() |
KafkaProperties.Listener.Type |
getType() |
void |
setAckCount(Integer ackCount) |
void |
setAckMode(org.springframework.kafka.listener.AbstractMessageListenerContainer.AckMode ackMode) |
void |
setAckTime(Duration ackTime) |
void |
setConcurrency(Integer concurrency) |
void |
setPollTimeout(Duration pollTimeout) |
void |
setType(KafkaProperties.Listener.Type type) |
public KafkaProperties.Listener.Type getType()
public void setType(KafkaProperties.Listener.Type type)
public org.springframework.kafka.listener.AbstractMessageListenerContainer.AckMode getAckMode()
public void setAckMode(org.springframework.kafka.listener.AbstractMessageListenerContainer.AckMode ackMode)
public Integer getConcurrency()
public void setConcurrency(Integer concurrency)
public Duration getPollTimeout()
public void setPollTimeout(Duration pollTimeout)
public Integer getAckCount()
public void setAckCount(Integer ackCount)
public Duration getAckTime()
public void setAckTime(Duration ackTime)
Copyright © 2017 Pivotal Software, Inc.. All rights reserved.