类 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()IntegergetAutoCommitInterval()StringgetAutoOffsetReset()List<String>getBootstrapServers()StringgetClientId()BooleangetEnableAutoCommit()IntegergetFetchMaxWait()IntegergetFetchMinSize()StringgetGroupId()IntegergetHeartbeatInterval()Class<?>getKeyDeserializer()IntegergetMaxPollRecords()KafkaProperties.SslgetSsl()Class<?>getValueDeserializer()voidsetAutoCommitInterval(Integer autoCommitInterval)voidsetAutoOffsetReset(String autoOffsetReset)voidsetBootstrapServers(List<String> bootstrapServers)voidsetClientId(