小编The*_*One的帖子

我想知道是否可以使用Flink Kafka接收器根据事件的类型编写不同主题的事件？假设我们有不同类型的事件：通知，消息和好友请求。我们希望将这些事件流式传输到不同的主题，这些主题分别是：notification-topic，messages-topic，friendsRequest-topic。

我尝试了多种方法来解决此问题，但仍然找不到正确的解决方案。我听说可以使用，ProcessFunction但如何将其与我的问题联系起来？