kafka 集群安装

建站不啰嗦，上手跟我做（十七）Kafka 集群部署

springboot 配置 kafka 信息

kafka:
  consumer:
    zookeeper.connect: 192.168.1.1:2181
    servers: 192.168.1.1:9092
    enable.auto.commit: false
    session.timeout: 60000
    auto.commit.interval: 100
    auto.offset.reset: latest
    group.id: consumer-group
# 每个消费者的线程数
    concurrency: 3
# 每一轮消费的时间间隔，超过时间间隔没有提交，kafka会重复推送消息
    max_poll_interval_ms: 60000
# 每一次拉取的消息条数
    max_poll_records: 20
  producer:
    servers: 192.168.1.1:9092
    retries: 3
    batch.size: 16384
    linger: 1
    buffer.memory: 3355432

配置信息详解

spring-kafka 配置详解

kafka 消费模式 AckMode 以及手动消费

kafka 消费模式 AckMode 以及手动消费

多消费者配置

多个消费者消费 kafka 消息

参数调整

kafka 常用命令

kafka 常用命令

kafka 分区分配策略

Kafka 分区分配策略

kafka 清理数据

kafka 清理数据