Kafka：“代理在增加分区后未能验证记录”

Question

我通过地形增加了现有卡夫卡主题的划分。分区大小成功地增加了，但是当我测试到主题的连接时，我得到了一个“代理无法验证记录”

测试方法：

 echo "test" | kcat -b ...
**sensitive content has been removed**
...

% Auto-selecting Producer mode (use -P or -C to override)
% Delivery failed for message: Broker: Broker failed to validate record

我试图在网上搜索，发现了一种叫做模式验证配置的东西：https://docs.confluent.io/cloud/current/sr/broker-side-schema-validation.html。

在增加分区之后，我需要做些什么吗？冲洗一些缓存？

Answer 1

您需要询问Kafka集群管理员是否启用了模式验证，但是增加分区不会导致这种情况。(这是的一个特性，而不是Apache )。

如果有人为您的主题更改了架构注册表中的架构，或者突然启用了验证，并且您正在从“旧”架构(或不正确的架构)发送记录，则代理将“无法验证”该记录。