我想对不同的 Java 对象使用单个 kafka 队列。我怎样才能实现这一目标？
PS:其中一种方法是将 JavaObject 转换为 JSON 字符串，并在接收端将其转换为所需的对象，如果此转换操作失败，我们可以优雅地处理它。但我认为这不是一个好的解决方案。
最佳答案
您可以在发送消息时向 kafka 消息添加 header ，并且根据 header 值，您可以在接收消息时将其转换为所需的对象。
关于java - 在 Java Spring boot 中是否有一种方法可以对不同的 Java 对象使用单个 kafka 队列？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/60669598/