使用消息队列Kafka版时客户端的报错及解决方案

• 网络问题
• 客户端鉴权（sasl.mechanisms）失败

  说明：该报错仅出现在消息队列Kafka版的公网实例中。

1. 确保servers配置正确。
2. 通过telnet命令排除网络问题。
3. 如果网络正常，请参考如下内容，确认鉴权正常。
   • RAM主子账号授权
   • 消息队列Kafka版Demo库
     

     说明：该方案仅适用于消息队列Kafka版的公网实例。

1. 登录消息队列Kafka版控制台。
2. 检查Topic是否已经创建。
3. 如果未创建，请先创建Topic。具体信息，请参见创建Topic。

array index out of bound exception

参考如下两种解决方法：

• 推荐同时使用Spring Cloud发送和消费。
• 如果您使用其他方式发送，例如，调用原生Java客户端发送，通过Spring Cloud消费时，需要设置headerMode为“raw”，即禁用解析消息内容。 具体信息，请参见Spring Cloud 官网。

No such configuration property: "sasl.mechanisms"

• C++
• 包装C++的客户端，例如，PHP、Node.js等。

参考如下命令安装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文件，放在任意目录下，这里假设为/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")

    注意：如果在代码中设置，请确保启动客户端之前代码能够被执行。

• 配置系统文件：在${JAVA_HOME}/jre/lib/java.security中增加内容：login.config.url.1=file:/home/admin/kafka_client_jaas.conf。

更多信息，请参见Oracle JAAS Login Configuration File。

Consumer拉取消息失败报错，可能的原因如下：

• 网络问题

• 拉取消息超时

1. 确保servers配置正确。
2. 通过telnet命令排除网络问题。
3. 如果网络正常，可能是拉取消息超时引起。可以尝试调整下列两个参数，限制单次拉取的消息量。
   • fetch.max.bytes：单次拉取操作，服务端返回的最大Bytes。
   • max.partition.fetch.bytes：单次拉取操作，服务端单个Partition返回的最大Bytes。
4. 服务端流量限制，可以在消息队列Kafka版控制台的实例详情页面查看相应内容：
   • VPC访问时查看峰值流量。
   • 公网访问时查看公网流量。

• 如果是云存储引擎：客户端版本大于等于3.0时，自动开启幂等功能， 但云存储不支持幂等功能。
• 如果是Local存储引擎：发送compact消息， 但未传递key值。

• 如果是云储存引擎：设置enable.idempotence=false。
• 如果是Local存储引擎：消息添加key值。