kafka批量消费配置


spring.kafka.bootstrap-servers=192.168.7.196:9092
spring.kafka.consumer.group-id=order_ck_group
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.auto-offset-reset=earliest
spring.kafka.consumer.enable-auto-commit=false
#最多拉取1000条数据
spring.kafka.consumer.max-poll-records=1000
#最长1000毫秒
spring.kafka.listener.type=batch
spring.kafka.listener.idle-between-polls=1000
spring.kafka.listener.ack-mode=manual_immediate
#topic名称
spring.kafka.topic=order_topic

上一篇:SpringBoot+Zookeeper+Dubbo整合(二)


下一篇:kafka原理总结