0
我目前使用的是windows機器，並且能夠通過命令提示符使用Kafka製作者和使用者讀取整個文件。我只需要獲取文件中的最近更改，並需要將其用作Apache flink的輸入。我嘗試使用this link，但由於kafka客戶端jar不匹配問題，我無法使用它。如何使用kafka製作者只讀取文件中的新更改
在我當前的方法中，當我每次加載整個文件時調用生產者，我們需要每次運行它以查看文件發生的更改。我想過使用線程和使用java代碼比較文件差異的一些方法，但有沒有隻通過Kafka做的。