我知道,可以使用風暴或火花流媒體做卡夫卡實時數據處理,但我想問是否有任何功能卡夫卡是類似於Flume攔截器數據清理等可以在一個事件中即時完成。卡夫卡數據處理沒有風暴/火花流媒體
0
A
回答
1
目前還沒有一個發佈版本卡夫卡,但下一個版本(0.10.0.0根據the roadmap)將有Kafka Streams看起來是相似的,你問什麼這樣的功能。
1
您正在尋找的是Kafka Interceptors,它實際上受到了Flume Interceptor Interface的啓發。就像@Lundahl指出目前的版本不支持這一點,但下一個版本將會支持。
相關問題
- 1. 卡夫卡火花流媒體整合
- 2. 卡夫卡風暴HDFS/S3數據流
- 3. 卡夫卡+火花流:kafka.common.OffsetOutOfRangeException
- 4. 火花,卡桑德拉,流媒體,蟒蛇,錯誤,數據庫,卡夫卡
- 5. 卡夫卡主題分區火花流
- 6. 卡夫卡火花流多個聚合
- 7. KafkaSpout(風暴)不在卡夫卡經理
- 8. 類沒有發現火花流和卡夫卡
- 9. 如何轉換卡夫卡流火花RDD或Spark數據幀
- 10. 卡夫卡文件流媒體
- 11. 星火1.6卡夫卡流媒體dataproc py4j錯誤
- 12. 閱讀火花批處理作業中的卡夫卡主題
- 13. 星火流掛卡夫卡在JavaStreamingContext.start,無火花工作創造
- 14. 如何整合風暴和卡夫卡
- 15. 卡夫卡風暴噴口lein或Mvn
- 16. 卡夫卡流火花不減少計數
- 17. 火花卡夫卡生產序列化
- 18. 火花,從uniq的卡夫卡要求
- 19. 卡夫卡與火花集成
- 20. 幫助有需要使用SBT建設罐子(卡夫卡 - 火花流媒體業務的情況下)
- 21. 卡夫卡流不在火花作業中工作
- 22. 閱讀最新的火花卡夫卡流
- 23. 火花 - 卡夫卡流異常 - 對象不是serializableConsumerRecord
- 24. 從卡夫卡火花流中的空值
- 25. 無法通過火花流消耗卡夫卡消息
- 26. 火花流每卡夫卡主題不同值解碼器
- 27. 卡夫卡火花流動動態模式
- 28. 蔭新卡夫卡和風暴,什麼是開始學習卡夫卡和風暴
- 29. 如何從卡夫卡的數據發送到火花
- 30. 重複的數據從卡夫卡紅移火花流和火花紅移連接器
謝謝!這有幫助。 – Gagan