java如何在kafka consumer中按内容设置主题？

Question

我想给卡夫卡发不同的信息。 它们按不同的主题分类。 但是，它属于哪一个主题取决于它的内容。 例如，这样的消息属于主题机

2021-7-21机器323中国杭州

我如何控制卡夫卡分发到不同的主题，而我只能知道在收到消息之前发送哪个主题

Answer 1

不清楚“获取消息”的位置，但在发送和序列化消息之前，您需要该消息，所以在那里获取主题名称

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

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

如果您从其他卡夫卡主题获取消息，可以使用KStreams branch将传入数据拆分为不同的拓扑/主题