-1
我想讀取kafka中的Apache日誌，然後進一步處理Spark Streaming.I是kafka的新手。據我瞭解，我必須編寫一個生產者類來讀取日誌文件。如何從kafka文件中讀取日誌？
A
回答
1
您可以通過創建一個連接器來將日誌文件的每一行輸入到Kafka主題中。看看這裏的例子：
https://docs.confluent.io/current/connect/devguide.html#connect-developing-simple-connector
相關問題
- 1. 如何讀取日誌從日誌文件，因爲它發生
- 2. FastMM4，如何讀取日誌文件？
- 3. 如何從heroku中的本地文件讀取日誌？
- 4. 如何從.jar文件獲取日誌？
- 5. 從文件夾中讀取所有日誌文件
- 6. 在java中讀取日誌文件
- 7. 如何在C++中讀取這個日誌文本文件
- 8. 將日誌文件kafka移動到hadoop
- 9. 在日誌解析器中讀取IIS日誌文件
- 10. php讀取大文本文件日誌
- 11. 如何使用c讀取.sil（SmartInspect文件）日誌文件＃
- 12. 從python中的日誌文件中讀取特定列
- 13. 如何讀取日誌文件並解析Java中的條目？
- 14. 如何在Junit測試中讀取日誌文件
- 15. 如何在Android中讀取系統日誌文件？
- 16. 如何在Perl中讀取持續更新的日誌文件？
- 17. 從bz2文件讀取日誌文件在objective-c
- 18. 如何閱讀更新日誌文件
- 19. 如何閱讀innodb日誌文件？
- 20. Q/kdb +按塊讀取日誌文件
- 21. Crashlytics無法讀取日誌文件
- 22. 使用PHP讀取IIS日誌文件
- 23. 如何在Cloud9中讀取Heroku日誌？
- 24. 如何在Heroku中讀取日誌？
- 25. 讀取事件日誌
- 26. 如何在日誌文件中獲取舊的日誌細節？
- 27. 如何使用文件夾讀取事件日誌？
- 28. 如何使用logstash將日誌文件寫入kafka？
- 29. 從日誌文件中讀取最後一行
- 30. 從日誌文件中讀取一個TB的數據
然後我可以寫消費者文件發送這些日誌在Spark流。 –