spring-boot - KafkaTemplate 线程安全吗

Question

Spring Boot 线程中的 KafkaTemplate 是否安全。我可以创建一个 KafkaTemplate 并使用它来将信息发送到同一 kafka 主题，以便在我的 Web 服务中进行多个请求。

Answer 1

是的，KafkaTemplate被设计为线程安全的。如果你看看它的 source code ，您会看到以下成员变量声明:

protected final Log logger = LogFactory.getLog(this.getClass()); //NOSONAR

private final ProducerFactory<K, V> producerFactory;

private final boolean autoFlush;

private final boolean transactional;

private final ThreadLocal<Producer<K, V>> producers = new ThreadLocal<>();

private RecordMessageConverter messageConverter = new MessagingMessageConverter();

private volatile String defaultTopic;

从 ThreadLocal 来看和 volatile变量定义，你可以推断它被设计为从多个线程使用，因此它必须是线程安全的(如果不是，那么你应该提交错误报告)。

如果设计师用信息性的 @ThreadSafe 对其进行注释会更好尽管或至少在类的 JavaDoc 注释中指出了这一点。