本地Kafka实例运行应用时ProducerRecord分区为null触发空指针异常

你遇到的record.partition()返回null的情况是Kafka Producer运行流程下的正常表现，并非单节点集群的异常，出现空指针也完全符合预期逻辑。
Kafka Producer的固定执行流程决定了，拦截器onSend()方法的运行时机早于分区计算环节：

• 当你使用new ProducerRecord<>("foo", allBytes)这类仅传入主题、消息值的构造方法创建记录时，记录自带的partition字段初始值就是null，不会自动填充为0。
• 生产端的流程顺序为：用户调用send()方法 -> 执行所有注册拦截器的onSend()逻辑 -> 调用内置Partitioner组件为消息计算目标分区、填充记录的分区字段 -> 执行key/value序列化 -> 将消息发送到Broker。
• 你的加密拦截器运行在分区计算完成之前，此时拿到的记录自然还没有被填充分区值，直接调用record.partition()拿到null，就会在构造Toppar对象时触发空指针。哪怕是单节点、单分区的集群，只要没有提前在构造记录时指定分区值，拦截器阶段拿到的分区值就一定是null。

• 如果是单节点、固定单分区的测试场景，最简单的修复方式是在构造ProducerRecord时显式指定分区值：把创建记录的代码调整为 new ProducerRecord<>("foo", 0, null, allBytes)，此时记录自带的分区值为0，拦截器拿到的分区字段就不会为null。
• 如果不希望硬编码分区号，不要在拦截器逻辑中提前依赖record.partition()的计算结果。你当前在拦截器中依赖分区值做的构造解码器缓存key、初始化Toppar对象的操作，都属于不需要在拦截器阶段提前完成的逻辑，可以将这部分逻辑后移到拦截器执行完成、分区值被填充之后的流程中处理。
• 同步修正拦截器的异常兜底逻辑：你当前catch块中返回的新记录，直接透传了可能为null的record.partition()值，即使走到异常分支，传递null分区值的记录依然会在后续流程触发空指针，这部分需要同步做非空判断处理。

补充说明：你代码里的try-with-resources块中声明的OutputStream outputStream = new FileOutputStream(outputFile);存在未定义outputFile变量的编译错误，建议先移除这段没有实际使用的流初始化代码，避免编译失败。

内容的提问来源于stack exchange，提问作者runnerpaul