我知道,可以使用风暴或火花流媒体做卡夫卡实时数据处理,但我想问是否有任何功能卡夫卡是类似于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