kafka-partition - 如何在kafka中创建分区
问题描述
我刚刚在新集群上升级了 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中启用这些分区
解决方案
推荐阅读
- flutter - NotifyListeners() 在 Flutter 中不能正常工作
- javascript - 使用制表符创建页面持久性
- c# - Release模式下的程序集反射问题
- java - java中的Haskell,我如何在java中实现“any”(haskell)?
- cypress - 赛普拉斯断言等于和大于
- mysql - 如何在 MySQL 中连接此脚本中的列?
- php - 具有动态 url 段的 nginx php-fpm 未被 php-fpm 解析
- perl - Perl tar 文件递归创建目录
- sql-server - SQL 嵌套连接问题
- pentaho - 如何在 PENTAHO 中将一行变成列