springboot中kafka消费之配置详解

kafka配置以下: kafka消费者默认开启线程池,能够经过consumer.concurrency来设置消费线程数java #原始数据kafka读取 kafka.consumer.servers=IP:9092,IP:9092(kafka消费集群ip+port端口) kafka.consumer.enable.auto.commit=true(是否自动提交) kafka.consumer.se
相关文章
相关标签/搜索