Spring Kafka可信包特性 | Baeldung

Kahen大约 5 分钟

Spring Kafka可信包特性 | Baeldung

寻找理想的Linux发行版，用于在云中运行现代Spring应用程序？

遇见Alpaquita Linux：轻量级、安全且功能强大，足以处理重负荷工作负载。

这个发行版是专门为运行Java应用程序而设计的。它基于Alpine，具有显著的增强功能，在高密度容器环境中表现出色，同时满足企业级安全标准。

具体来说，容器镜像大小比标准选项小约30%，并且消耗的RAM少至30%：

>> 立即尝试Alpaquita容器。

1. 引言

在本教程中，我们将回顾Spring Kafka可信包特性。我们将看到它背后的动机以及它的用法。像往常一样，都有实际的例子。

2. 先决条件

通常，Spring Kafka模块允许我们作为用户指定一些关于我们发送的POJO的元数据。它通常以Kafka消息头的形式出现。例如，如果我们这样配置_ProducerFactory_：

@Bean
public ProducerFactory`<Object, SomeData>` producerFactory() {
    JsonSerializer```<SomeData>``` jsonSerializer = new JsonSerializer<>();
    jsonSerializer.setAddTypeInfo(true);
    return new DefaultKafkaProducerFactory<>(
      producerFactoryConfig(),
      new StringOrBytesSerializer(),
      jsonSerializer
    );
}

@Data
@AllArgsConstructor
static class SomeData {
    private String id;
    private String type;
    private String status;
    private Instant timestamp;
}

然后我们将使用上述配置的_kafkaTemplate_将新消息发送到一个主题：

public void sendDataIntoKafka() {
    SomeData someData = new SomeData("1", "active", "sent", Instant.now());
    kafkaTemplate.send(new ProducerRecord<>("sourceTopic", null, someData));
}

在这种情况下，我们将在Kafka消费者的控制台中看到以下消息：

CreateTime:1701021806470 __TypeId__:com.baeldung.example.SomeData null {"id":"1","type":"active","status":"sent","timestamp":1701021806.153965150}

正如我们所看到的，消息中POJO的类型信息在头文件中。这当然是Spring Kafka特性，Spring只识别。这意味着，从Kafka或其他框架的角度来看，这些头文件只是元数据。因此，我们可以假设这里的消费者和生产者都使用Spring来处理Kafka消息。

话虽如此，我们可以说，在某些情况下，这是一个相当有用的特性。当主题中的消息具有不同的负载架构时，为消费者提供负载类型的提示将是很好的。

然而，通常我们知道主题中可能出现的消息类型及其架构。因此，限制消费者将接受的可能的负载架构可能是一个好主意。这就是Spring Kafka可信包特性的用途。

4. 使用示例

可信包Spring Kafka特性在反序列化器级别上配置。如果配置了可信包，那么Spring将查找传入消息的类型头文件。然后，它将检查消息中提供的所有类型（键和值）是否受信任。

这基本上意味着键和值的Java类，指定在相应的头文件中，必须位于可信包内。如果一切正常，那么Spring将消息传递给进一步的反序列化。如果头文件不存在，那么Spring只会反序列化对象，而不会检查可信包：

@Bean
public ConsumerFactory`<String, SomeData>` someDataConsumerFactory() {
    JsonDeserializer```<SomeData>``` payloadJsonDeserializer = new JsonDeserializer<>();
    payloadJsonDeserializer.addTrustedPackages("com.baeldung.example");
    return new DefaultKafkaConsumerFactory<>(
      consumerConfigs(),
      new StringDeserializer(),
      payloadJsonDeserializer
    );
}

还值得一提的是，如果用星号(*)替换具体包，Spring可以信任所有包：

JsonDeserializer```<SomeData>``` payloadJsonDeserializer = new JsonDeserializer<>();
payloadJsonDeserializer.trustedPackages("*");

然而，在这种情况下，使用可信包不会做任何事情，只会增加额外的开销。现在让我们跳到我们刚刚看到的特性背后的动机。

Spring Kafka可信包特性 | Baeldung

Spring Kafka可信包特性 | Baeldung

1. 引言

2. 先决条件

4. 使用示例

5.1. 第一个动机：一致性

5.2. 第二个动机：安全

6. 结论