0

我刚刚在新集群上升级了 kafka,并添加到我的 kubernetes 清单中:spec: kafka: version: 2.7.0 partitions: 12 replicas: 3

仍然当我通过执行以下操作检查 Zookeeper 时: kubectl -n centralised-logging exec my-cluster-kafka-2 -- bash bin/kafka-topics.sh --zookeeper zookeeper --describe --topic logstash

我看到我的 logstash 正在将数据发送到 12 个分区,但是当我重置偏移量时。我只看到一个。所以不确定如何在kafka中启用这些分区

4

0 回答 0