Kafka样例程序开发思路

场景说明

Kafka是一个分布式消息系统，在此系统上可以做一些消息的发布和订阅操作，假定用户要开发一个Producer，让其每秒向Kafka集群某Topic发送一条消息，另外，还需要实现一个Consumer，订阅该Topic，实时消费该类消息。

开发思路

1. 使用Linux客户端创建一个Topic。
2. 开发一个Producer向该Topic生产数据。
3. 开发一个Consumer消费该Topic的数据。