使用消息队列Kafka版时客户端的报错如何解决? -问答-阿里云开发者社区-阿里云

开发者社区> 保持可爱mmm> 正文

使用消息队列Kafka版时客户端的报错如何解决?

2020-03-28 18:39:10 386 1

使用消息队列Kafka版时客户端的报错如何解决?

取消 提交回答
全部回答(1)
  • 保持可爱mmm
    2020-03-28 18:39:52

    概述 在使用消息队列Kafka版时,客户端可能报错,您可以根据报错消息匹配对应的解决方案。 详细信息 报错信息对应的详细信息如下。 报错信息 客户端语言类型 报错原因 解决方案 TimeoutException Java 网络问题 客户端鉴权(sasl.mechanisms)失败 说明 该报错仅出现在消息队列Kafka版的公网实例中。 确保servers配置正确。 通过telnet命令排除网络问题。 如果网络正常,请参考如下内容,确认鉴权正常。 RAM主子账号授权 消息队列Kafka版Demo库 说明 该方案仅适用于消息队列Kafka版的公网实例。 run out of brokers Go Authentication failed for user Python Leader is not available 所有 Topic初始化时会短暂报该错误。如果持续报错,可能是因为没有创建Topic。 登录消息队列Kafka版的控制台。 检查Topic是否已经创建。 如果未创建,请先创建Topic。具体信息,请参见创建Topic。 leader is in election array index out of bound exception Java Spring Cloud会按自己的格式解析消息内容。 参考如下两种解决方法。 推荐同时使用Spring Cloud发送和消费。 如果您使用其他方式发送,例如,调用Kafka原生Java客户端发送,通过Spring Cloud消费时,需要设置headerMode为“raw”,即禁用解析消息内容。 具体信息,请参见Spring Cloud 官网。 No such configuration property: "sasl.mechanisms" C++ 包装C++的客户端,例如,PHP、Node.js等。 SASL和SSL模块未安装或安装异常。 参考如下命令安装SASL和SSL模块。 说明 此处以CentOS系统为例,其他系统请查阅相关官网或者第三方搜索引擎。 安装SSL:sudo yum install openssl openssl-devel 安装SASL:sudo yum install cyrus-sasl{,-plain} No worthy mechs found No KafkaClient Entry Java 未找到kafka_client_jaas.conf配置文件。 准备好 kafka_client_jaas.conf文件,放在任意目录下,这里假设为/home/admin。Java的安全登录设置是系统性的,有如下两种设置方法。 设置系统变量 通过设置JVM参数:-Djava.security.auth.login.config=/home/admin/kafka_client_jaas.conf 通过代码设置:System.setProperty("java.security.auth.login.config","/home/admin/kafka_client_jaas.conf") 注意 如果在代码中设置,一定要保证代码在启动Kafka客户端之前执行。 配置系统文件:在${JAVA_HOME}/jre/lib/java.security中增加内容:login.config.url.1=file:/home/admin/kafka_client_jaas.conf。 更多信息,请参见 Oracle JAAS Login Configuration File。 Error sending fetch request Java Consumer拉取消息失败报错,可能的原因如下。 网络问题 拉取消息超时 确保servers配置正确。 通过telnet命令排除网络问题。 如果网络正常,可能是拉取消息超时引起。可以尝试调整下列两个参数,限制单次拉取的消息量。 fetch.max.bytes:单次拉取操作,服务端返回的最大Bytes。 max.partition.fetch.bytes:单次拉取操作,服务端单个Partition返回的最大Bytes。 服务端流量限制,可以在消息队列Kafka版控制台的实例详情页面查看相应内容。 VPC访问时查看峰值流量。 公网访问时查看公网流量。 DisconnectException 适用于 消息队列 Kafka 版 如果您的问题仍未解决,您可以在阿里云社区免费咨询,或提交工单联系阿里云技术支持。

    0 0
相关问答

4

回答

Spark 【问答合集】

社区小助手 2019-05-29 14:13:40 123644浏览量 回答数 4

37

回答

ISV接入钉钉详细示例以及代码(JAVA版本)  --服务窗代码部分放出

蛋蛋oo蛋蛋 2016-08-13 16:22:00 54959浏览量 回答数 37

17

回答

【精品问答】Java技术1000问(1)

问问小秘 2019-11-15 11:24:15 52643浏览量 回答数 17

2

回答

Kafka、ActiveMQ、RabbitMQ、RocketMQ的区别?【Java问答学堂】19期

剑曼红尘 2020-05-15 11:24:19 32047浏览量 回答数 2

18

回答

【阿里云产品公测】消息队列服务MQS java SDK 机器人应用 初体验

啊里新人 2014-10-11 14:00:19 29192浏览量 回答数 18

9

回答

【6.27更新】你不能错过的:阿里中间件性能挑战赛重要学习资料

凝岚 2016-04-16 15:26:05 30158浏览量 回答数 9

11

回答

一小时入门阿里云IoT套件

三野 2016-11-18 11:37:24 32790浏览量 回答数 11

1

回答

消息队列有什么优点和缺点?【Java问答学堂】18期

剑曼红尘 2020-05-14 11:26:31 29466浏览量 回答数 1

1

回答

为什么使用消息队列?【Java问答学堂】17期

剑曼红尘 2020-05-13 20:39:29 28942浏览量 回答数 1

1

回答

安装rabbitmq的问题

游客duaxdk4r3ques 2019-04-02 17:15:05 29838浏览量 回答数 1
66
文章
12595
问答
推荐问答
相关电子书
更多
文娱运维技术
立即下载
《SaaS模式云原生数据仓库应用场景实践》
立即下载
《看见新力量:二》电子书
立即下载