1
我有一個和Zookeeper一起工作的Kafka實例。實際上，我可以在Windows上使用命令行來創建生產者消費者，我在生產者上編寫一些字符串，並將它們顯示在消費者上。 我的目標是使用Kafka和一些Java代碼實現文件「傳輸」。我想用卡夫卡「讀」然後「寫」一個文件。用java代碼使用kafka
爲了實現這一目標，我把現有的代碼在這個倉庫：
據我瞭解，SinkConnector和TaksConnector將在So中寫入文件urceConnector和SourceTask將讀取它。
我的問題是，我不知道如何使用此代碼的主要和如何使用它與卡夫卡實例。