时间戳

首页 > 解决方案 > 在 Java Spring boot 中有没有一种方法可以将单个 kafka 队列用于不同的 Java 对象？

java - 在 Java Spring boot 中有没有一种方法可以将单个 kafka 队列用于不同的 Java 对象？

问题描述

我想为不同的 Java 对象使用单个 kafka 队列。我怎样才能做到这一点？

PS：其中一种方法是将 JavaObject 转换为 JSON 字符串，并在接收端将其转换为所需的对象，如果此转换操作失败，我们可以优雅地处理它。但我认为这不是一个好的解决方案。

标签： javaspring-bootapache-kafkaspring-kafka

解决方案

您可以在发送 msg 时向 kafka 消息添加标头，并根据标头值将其转换为所需的对象，同时接收它..

推荐阅读