java - 如何在kafka消费者中按内容设置主题？

Question

我想向kafka发送不同的消息。它们按不同的主题分类。但是它属于哪个主题是在它的内容中设置的。例如，这样的消息属于主题机器。

2021-7-21机323中国杭州

如何控制 kafka 分发到不同的主题，而我只能知道要发送哪个主题，直到我收到消息？

标签： javaapache-kafkabackend

Answer 1

不清楚您“获取消息”的位置，但您需要该消息才能发送和序列化，因此在此处获取主题名称

Producer<?, Message> p = new KafkaProducer<>(...)
Message m = ...

p.send(new ProducerRecord<>(m.getYourField(), m));

如果您从其他 Kafka 主题获取消息，您可以使用 KStreamsbranch将传入数据拆分到不同的拓扑/主题