I built an OSS pusher protocol alternative, and have this same problem with the fan-in. I got around it by using a library called Hazelcast which does distributed data structures among clusters. It also includes topic subscription functionality, which is something I used.

There is another pusher protocol implementation called Slanger, and they use Redis for centralized pubsub, which has pubsub built in.