请教各位大佬一个问题

需求：

1 客户端： windows 客户端，java 编程读取本地 csv 文件（下载的一个数据集，全为 csv 文件）， 编写 socket 程序实现读取到的一个个 csv 文件数据的传输。

2 服务端： 在服务器上，利用 java socket 使得 kafka 与客户端建立链接，kafka 获取到客户端一个个的 csv 文件数据。然后进行数据处理分析。

我看了看 java socket 是需要在客户端和服务端窦要编写程序，按照我的需求怎么实现还不会。请各位大神指点指点。谢谢。