如何在Kafka的不同主题中传达不同的信息

jw5wzhpr 于 2021-06-08 发布在 Kafka

关注(0)|答案(2)|浏览(325)

我有不同主题的制作人。所有的生产者都在监听同一个文件，它每秒接收多个事件，所有的事件都是不同的。请找到下面的样品。 A event1 B event2 C event3 A event4 C event5 B event6 D event7 E event8 F event9 E event10 将每个事件视为一条消息。如何从侦听事件文件的生产者列表中将不同的消息定向到相应的主题。
谢谢。当做，

apache-kafka apache-kafka-connect kafka-producer-api apache-kafka-streams kafka-consumer-api

来源：https://stackoverflow.com/questions/44431113/how-to-direct-different-message-to-diferent-topics-in-kafka

2条答案

按热度按时间

a5g8bdjr1#

为什么不让一个Kafka制作人监听输入文件，并根据文件中写入的每个新事件的内容发布不同的主题呢？

赞(0）回复(0）举报 2021-06-09

63lcw9qa2#

你看过Kafka的文件了吗？
https://kafka.apache.org/documentation/#producerapi
https://kafka.apache.org/0102/javadoc/index.html?org/apache/kafka/clients/producer/kafkaproducer.html
假设 A , B 等是所需目标主题的名称，只需将“我的主题”替换为 A 等等，代码如下：

Producer<String, String> producer = new KafkaProducer<>(props);
producer.send(new ProducerRecord<String, String>("my-topic", "my-key", "my-value");

赞(0）回复(0）举报 2021-06-08

我来回答

如何在Kafka的不同主题中传达不同的信息

2条答案

相关问题

热门标签

最新问答