通过

你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站，请访问 https://docs.azure.cn。

针对事件中心的 Apache Kafka 故障排除指南

  • 项目

本文提供的故障排除技巧适用于你在使用适用于 Apache Kafka 的事件中心时可能会遇到的问题。

服务器繁忙异常

由于 Kafka 限制，你可能会收到“服务器忙”异常。 使用 AMQP 客户端时，事件中心会在遇到服务限制时立即返回“服务器忙”异常。 它相当于“稍后重试”消息。 在 Kafka 中，消息在完成前会存在延迟。 将在生成/提取响应中以 throttle_time_ms 形式返回延迟时间长度（以毫秒为单位）。 大多数情况下，系统不会在事件中心仪表板上将这些延迟的请求记录为“服务器忙”异常， 而是使用响应的 throttle_time_ms 值来指示吞吐量已超出预配的配额。

如果流量过多，服务会出现以下行为：

  • 如果生成请求的延迟超过请求超时 (request.timeout.ms)，事件中心会返回“策略冲突”错误代码。
  • 如果提取请求的延迟超过请求超时，事件中心会将请求记录为“受限制”并以空记录集进行响应，不返回错误代码。

专用群集没有限制机制。 你可以自由地使用所有群集资源。

未收到记录

你可能会看到，使用者未收到任何记录，并且会不断地重新进行平衡。 在这种情况下，使用者不会获得任何记录，只会不断地重新进行平衡。 它发生时没有异常或错误，但 Kafka 日志会显示使用者在尝试重新加入组和分配分区时处于停滞状态。 此问题有多种可能的原因：

  • 确保 request.timeout.ms 至少为建议值 60000，session.timeout.ms 至少为建议值 30000。 这些设置过低可能会导致使用者超时，超时会导致重新平衡（重新平衡又会导致超时，而超时又会导致重新平衡，陷入一个死循环）
  • 如果你的配置与这些建议的值相符，而你仍然看到系统在不断地进行重新平衡，则请提交问题（请确保在问题中提供完整的配置，方便我们进行调试）！

压缩/消息格式版本问题

Kafka 的事件中心目前仅支持 gzip 压缩算法。 如果使用任何其他算法，客户端应用程序将看到消息格式版本错误（例如，The message format version on the broker does not support the request.）。

如果需要使用不受支持的压缩算法，请在将数据发送到中转站之前使用该特定算法压缩数据，在接收数据之后再将其解压缩，这是一种有效的解决方法。 消息正文只是发送给服务的字节数组，因此客户端压缩/解压缩不会导致任何问题。

UnknownServerException

你可能会收到一个 Kafka 客户端库中的 UnknownServerException，类似于以下示例：

org.apache.kafka.common.errors.UnknownServerException: The server experienced an unexpected error when processing the request

通过 Microsoft 支持部门开具一个票证。 在调试问题时，调试级别的日志记录和异常时间戳 (UTC) 很有用。

其他问题

如果在事件中心使用 Kafka 时遇到问题，请检查以下项。

  • 防火墙阻止流量 - 确保防火墙未阻止端口 9093。
  • TopicAuthorizationException - 此异常的最常见原因包括：
    • 配置文件中的连接字符串中有拼写错误，或者
    • 尝试在“基本”层命名空间中使用用于 Kafka 的事件中心。 基本层不支持适用于 Kafka 的事件中心的功能。
  • Kafka 版本不匹配 - 用于 Kafka 生态系统的事件中心支持 Kafka 1.0 及更高版本。 某些使用 Kafka 0.10 及更高版本的应用程序有时可能会有效，因为 Kafka 协议具有后向兼容性，但我们强烈建议你不要使用旧的 API 版本。 Kafka 0.9 及更低版本不支持必需的 SASL 协议，因此无法连接到事件中心。
  • 与 Kafka 配合使用时，AMQP 标头上出现奇怪的编码 - 通过 AMQP 将事件发送到事件中心时，系统会采用 AMQP 编码来序列化任何 AMQP 有效负载标头。 Kafka 使用者不会反序列化 AMQP 中的标头。 若要读取标头值，请手动解码 AMQP 标头。 或者，如果你知道要通过 Kafka 协议来使用 AMQP 标头，则可避免使用这些标头。 有关详细信息，请参阅此 GitHub 问题。
  • SASL 身份验证 - 将框架与事件中心所需的 SASL 身份验证协议配合使用可能不是看起来那么容易。 看看你是否可以在 SASL 身份验证的基础上使用框架的资源来排查配置问题。

限制

我们可以将 Apache Kafka 与事件中心 Kafka 进行比较。 大多数情况下，Azure 事件中心的 Kafka 接口的默认值、属性、错误代码和常规行为与 Apache Kafka 的相同。 下面列出了这二者明显不同的情况（或事件中心施加了某个限制而 Kafka 没有施加该限制的情况）：

  • group.id 属性的最大长度为 256 个字符
  • offset.metadata.max.bytes 的最大大小为 1024 个字节
  • 偏移提交数限制为每个分区 4 个调用/秒，内部日志最大大小为 1 MB

后续步骤

若要详细了解事件中心和适用于 Kafka 的事件中心，请参阅以下文章：