/usr/local/kafka/bin/kafka-consumer-groups.sh --bootstrap-server ${ENV_KAFKA_ENDPOINTS:=127.0.0.1:9092} --describe --group md-workflow-consumer
请
登录后发表观点
吴言飞(Team) 2022-11-13 17:19:19图中应该是您执行调整为 10 个分区命令后所报的错误吧?较新的版本目前默认分区数已经调整为 10 了;
如果您在微服务容器内执行单机模式查看分区数及消息堆积的命令时依旧有报错,请参考以下方式:
1. 下载kafka的安装包 wget http://pdpublic.mingdao.com/private-deployment/offline/common/kafka_2.12-2.8.0.tgz 2. 将下载的文件拷贝到容器内,如: docker cp kafka_2.12-2.8.0.tgz 容器ID:/tmp 3. 进入容器内的/tmp/kafka_2.12-2.8.0/bin/目录,然后再执行查看分区数的命令: ./kafka-consumer-groups.sh --bootstrap-server ${ENV_KAFKA_ENDPOINTS:=127.0.0.1:9092} --describe --group md-workflow-consumer
记得更新一下你们的帮助文档中的 faq,我们还以为是哪里操作有问题
图中应该是您执行调整为 10 个分区命令后所报的错误吧?较新的版本目前默认分区数已经调整为 10 了;
如果您在微服务容器内执行单机模式查看分区数及消息堆积的命令时依旧有报错,请参考以下方式:
1. 下载kafka的安装包
wget http://pdpublic.mingdao.com/private-deployment/offline/common/kafka_2.12-2.8.0.tgz
2. 将下载的文件拷贝到容器内,如:
docker cp kafka_2.12-2.8.0.tgz 容器ID:/tmp
3. 进入容器内的/tmp/kafka_2.12-2.8.0/bin/目录,然后再执行查看分区数的命令:
./kafka-consumer-groups.sh --bootstrap-server ${ENV_KAFKA_ENDPOINTS:=127.0.0.1:9092} --describe --group md-workflow-consumer