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相关推荐

【Kafka】 kafka 启动 Connection to node 1 could not be established. Broker may not be available
1.背景在文章:[Kafka]Kafka 配置 SASL_SSL jks鉴权验证方式文章的第 16 章的时候,设置远程连接的时候,报错如下 [2020-08-26 22:18:31,309
【Kafka】failed due to invalid credentials with broker older than 1.1.0
1.背景参考:[Kafka]Kafka 配置 SASL_SSL jks鉴权验证方式这篇文章,这个我在本机测试通过了,然后在服务器的docker容器中也搭建了一套. 环境如下 192.168.1.1 ...
【kafka】kerberos Server not found in Kerberos database LOOKING_UP_SERVER Identifier doesn‘t match
文章目录 1.概述 2.配置如下 3.测试 1.概述首先参考kafka的配置环境:[kafka]kerberos认证下 kafka 报错Bootstrap broker host:ip (id: - ...
【kafka】kerberos client is being asked for a password not available to garner authentication informa
文章目录 1.场景1 1.1 概述 1.2.具体测试 2.场景2 3.1 概述 3.2 解决 1.场景1 关联文章: [zookeeper]zookeeper的ACL权限控制 1.1 概述首先参考k ...
【kafka】Unexpected handshake request with client mechanism GSSAPI, enabled mechanisms are
文章目录 1.概述 1.概述首先参考kafka的配置环境:[kafka]kerberos认证下 kafka 报错Bootstrap broker host:ip (id: -1 rack: null ...
【kafka】kafka 2.4 static membership功能 group.instance.id
1.概述首先参考文章:[kafka]Kafka消费者分区分配策略详解 2.官网地址:Static Membership 静态成员关系旨在提高流应用程序.消费者组和其他构建在组再平衡协议之上的应用程 ...
【kafka】Kafka consumer处理大消息数据过大导致消费停止问题
文章目录 1.概述 2.案例分析 3.kafka的设计初衷 3.1 broker 配置 3.2 Consumer 配置 M.扩展 1.概述转载:https://www.cnblogs.com/wyn ...
【kafka】Kafka Fetch Session 剖析
1.概述转载:https://www.cnblogs.com/smartloli/p/14352489.html 1.概述最近有同学留言在使用Kafka的过程中遇到一些问题,比如在拉取的Topic ...
【Kafka】Kafka WARN Failed to send SSL Close message
1.背景在 [Kafka]failed due to invalid credentials with broker older than 1.1.0 的背景下,忘记怎么滴了报错如下 [2017- ...

【Kafka】UnsupportedVersionException: The broker does not support DESCRIBE_LOG_DIRS

1.概述

【Kafka】UnsupportedVersionException: The broker does not support DESCRIBE_LOG_DIRS相关推荐

最新文章

热门文章