1.概述
背景参考：【Kafka】kafka Java api 获取 kafka topic 或者 partition 占用的磁盘大小
这个是因为你的版本不对
Exception in thread "main" java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.UnsupportedVersionExceptio【Kafka】UnsupportedVersionException: The broker does not support DESCRIBE_LOG_DIRS
猜你喜欢
转载自blog.csdn.net/qq_21383435/article/details/108637055
今日推荐
周排行