类 KafkaProperties.Consumer
- java.lang.Object
- org.springframework.boot.autoconfigure.kafka.KafkaProperties.Consumer
- 封闭类:
- KafkaProperties
public static class KafkaProperties.Consumer extends Object
构造器概要
构造器 构造器 说明 Consumer()
方法概要
所有方法 实例方法 具体方法 修饰符和类型 方法 说明 Map<String,Object>
buildProperties()
Integer
getAutoCommitInterval()
String
getAutoOffsetReset()
List<String>
getBootstrapServers()
String
getClientId()
Boolean
getEnableAutoCommit()
Integer
getFetchMaxWait()
Integer
getFetchMinSize()
String
getGroupId()
Integer
getHeartbeatInterval()
Class<?>
getKeyDeserializer()
Integer
getMaxPollRecords()
KafkaProperties.Ssl
getSsl()
Class<?>
getValueDeserializer()
void
setAutoCommitInterval(Integer autoCommitInterval)
void
setAutoOffsetReset(String autoOffsetReset)
void
setBootstrapServers(List<String> bootstrapServers)
void
setClientId(