kafka，建议换成 nats

https://GitHub.com/nats-io/nats-streaming-server 提供参考。