Key_Shared订阅模式场景需求

环境描述：
1、多台服务器，分别单独部署flink应用，每一台服务器上的flink应用相对独立，即：每一台服务器上都是1 master+1 slaver；
2、所有的flink应用，订阅同一个Pulsar Topic，采用Key_Shared订阅模式；
场景描述：
Topic中的数据，需要按照不同Key进行消费，同时，需要把相同的Key分到同一个flink进行应用（有时序的要求）。
Key不是预先固定设置的，通常是采集的目标数据对象的唯一标识，比如：目标设备的IP地址作为Key，也就是Key是变化的。

希望社区的老铁们，帮忙提供下Key_Shared订阅模式的参考实现，感谢！
