apache-kafka - 卡夫卡我的一些消费者不消费

Question

我有一个有 32 个分区的主题，其中都有数据。

但是当我启动多个消费者对其进行消费时，只有 4 个消费者可以获取数据形式的主题。

主题元数据：

这是监控仪表板：

这里是最终的统计数据：

补充消费者配置：

import "gopkg.in/confluentinc/confluent-kafka-go.v1/kafka"

config := kafka.ConfigMap{
        "broker.address.family": "v4", // Avoid connecting to IPv6 brokers
        "bootstrap.servers":     addr,
        "group.id":              groupID,
        "session.timeout.ms":    6000,
        "auto.offset.reset":     "earliest",
    }

标签： apache-kafka

Answer 1

确保多个消费者具有唯一的客户端 ID。特别是如果消费者是同一操作系统进程的一部分。